Skip to content

Commit 1d9e0d4

Browse files
yakudyakud
authored
Merge pull request #302 from badaitech/feat/flow-initialize-enhance
Enhanced Flow Initialization and Distributed Execution with Kafka Integration
2 parents f8318a8 + 2f8da15 commit 1d9e0d4

54 files changed

Lines changed: 2233 additions & 1978 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎.changeset/pre.json‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,16 +17,20 @@
1717
"afraid-needles-greet",
1818
"angry-llamas-divide",
1919
"beige-geese-show",
20+
"brave-webs-refuse",
2021
"chubby-numbers-enjoy",
2122
"cold-news-fold",
2223
"easy-candies-smile",
2324
"full-readers-itch",
25+
"hip-doors-notice",
2426
"hungry-words-hang",
2527
"loud-gifts-tell",
28+
"lovely-areas-count",
2629
"modern-pants-train",
2730
"olive-ears-camp",
2831
"proud-clouds-report",
2932
"rude-parts-heal",
33+
"sixty-humans-smile",
3034
"tiny-things-report",
3135
"tired-days-sleep"
3236
]

‎apps/chaingraph-backend/CHANGELOG.md‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,29 @@
11
# @badaitech/chaingraph-backend
22

3+
## 0.5.5-dev.18
4+
5+
### Patch Changes
6+
7+
- feat: enhance GraphQL client integration, optimize Kafka configurations, and update message fields
8+
9+
## 0.5.5-dev.17
10+
11+
### Patch Changes
12+
13+
- feat: enhance module exports and update dependencies for computed and complex ports
14+
15+
## 0.5.5-dev.16
16+
17+
### Patch Changes
18+
19+
- feat: enhance module exports by refining imports for computed and complex ports
20+
21+
## 0.5.5-dev.15
22+
23+
### Patch Changes
24+
25+
- feat: add distributed execution mode and enhance module imports for computed and complex ports
26+
327
## 0.5.5-dev.14
428

529
### Patch Changes

‎apps/chaingraph-backend/package.json‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
{
22
"name": "@badaitech/chaingraph-backend",
33
"type": "module",
4-
"version": "0.5.5-dev.14",
4+
"version": "0.5.5-dev.18",
55
"private": false,
66
"description": "Backend server for the Chaingraph project",
77
"license": "BUSL-1.1",

‎apps/chaingraph-execution-api/.env.example‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,11 @@ PORT=4021
66
DATABASE_URL=postgres://postgres@0.0.0.0:5435/postgres?sslmode=disable
77
DATABASE_URL_EXECUTIONS=postgres://postgres@0.0.0.0:5435/postgres?sslmode=disable
88

9+
EXECUTION_MODE=distributed
10+
911
# Kafka (required for distributed mode)
1012
KAFKA_BROKERS=localhost:9092
13+
KAFKA_TOPICS_PREFIX=dev.
1114

1215
# Logging
1316
# debug, info, warn, error

‎apps/chaingraph-execution-api/CHANGELOG.md‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,45 @@
11
# @badaitech/chaingraph-execution-api
22

3+
## 0.5.5-dev.18
4+
5+
### Patch Changes
6+
7+
- feat: enhance GraphQL client integration, optimize Kafka configurations, and update message fields
8+
- Updated dependencies
9+
- @badaitech/chaingraph-executor@0.5.5-dev.18
10+
- @badaitech/chaingraph-types@0.5.5-dev.18
11+
- @badaitech/chaingraph-trpc@0.5.5-dev.18
12+
13+
## 0.5.5-dev.17
14+
15+
### Patch Changes
16+
17+
- feat: enhance module exports and update dependencies for computed and complex ports
18+
- Updated dependencies
19+
- @badaitech/chaingraph-executor@0.5.5-dev.17
20+
- @badaitech/chaingraph-types@0.5.5-dev.17
21+
- @badaitech/chaingraph-trpc@0.5.5-dev.17
22+
23+
## 0.5.5-dev.16
24+
25+
### Patch Changes
26+
27+
- feat: enhance module exports by refining imports for computed and complex ports
28+
- Updated dependencies
29+
- @badaitech/chaingraph-executor@0.5.5-dev.16
30+
- @badaitech/chaingraph-types@0.5.5-dev.16
31+
- @badaitech/chaingraph-trpc@0.5.5-dev.16
32+
33+
## 0.5.5-dev.15
34+
35+
### Patch Changes
36+
37+
- feat: add distributed execution mode and enhance module imports for computed and complex ports
38+
- Updated dependencies
39+
- @badaitech/chaingraph-executor@0.5.5-dev.15
40+
- @badaitech/chaingraph-types@0.5.5-dev.15
41+
- @badaitech/chaingraph-trpc@0.5.5-dev.15
42+
343
## 0.5.5-dev.14
444

545
### Patch Changes

‎apps/chaingraph-execution-api/package.json‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
{
22
"name": "@badaitech/chaingraph-execution-api",
33
"type": "module",
4-
"version": "0.5.5-dev.14",
4+
"version": "0.5.5-dev.18",
55
"private": false,
66
"description": "Chaingraph tRPC Server - Scalable API server for Chaingraph execution management",
77
"license": "BUSL-1.1",

‎apps/chaingraph-execution-api/src/config.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ export const config = {
2727
// Kafka configuration (needed for distributed mode)
2828
kafka: {
2929
brokers: (process.env.KAFKA_BROKERS || 'localhost:9092').split(','),
30-
topicsPrefix: process.env.KAFKA_TOPICS_PREFIX || 'chaingraph',
30+
topicsPrefix: process.env.KAFKA_TOPICS_PREFIX || '',
3131
},
3232

3333
// Logging

‎apps/chaingraph-execution-worker/.env.example‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@ DATABASE_URL_EXECUTIONS=postgres://postgres@0.0.0.0:5435/postgres?sslmode=disabl
1919

2020
# Kafka (required for distributed mode)
2121
KAFKA_BROKERS=localhost:9092
22+
KAFKA_TOPICS_PREFIX=dev.
2223

2324
# Health Monitoring
2425
# Port for health endpoint

‎apps/chaingraph-execution-worker/CHANGELOG.md‎

Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,49 @@
11
# @badaitech/chaingraph-execution-worker
22

3+
## 0.5.5-dev.18
4+
5+
### Patch Changes
6+
7+
- feat: enhance GraphQL client integration, optimize Kafka configurations, and update message fields
8+
- Updated dependencies
9+
- @badaitech/chaingraph-executor@0.5.5-dev.18
10+
- @badaitech/chaingraph-nodes@0.5.5-dev.18
11+
- @badaitech/chaingraph-types@0.5.5-dev.18
12+
- @badaitech/chaingraph-trpc@0.5.5-dev.18
13+
14+
## 0.5.5-dev.17
15+
16+
### Patch Changes
17+
18+
- feat: enhance module exports and update dependencies for computed and complex ports
19+
- Updated dependencies
20+
- @badaitech/chaingraph-executor@0.5.5-dev.17
21+
- @badaitech/chaingraph-nodes@0.5.5-dev.17
22+
- @badaitech/chaingraph-types@0.5.5-dev.17
23+
- @badaitech/chaingraph-trpc@0.5.5-dev.17
24+
25+
## 0.5.5-dev.16
26+
27+
### Patch Changes
28+
29+
- feat: enhance module exports by refining imports for computed and complex ports
30+
- Updated dependencies
31+
- @badaitech/chaingraph-executor@0.5.5-dev.16
32+
- @badaitech/chaingraph-nodes@0.5.5-dev.16
33+
- @badaitech/chaingraph-types@0.5.5-dev.16
34+
- @badaitech/chaingraph-trpc@0.5.5-dev.16
35+
36+
## 0.5.5-dev.15
37+
38+
### Patch Changes
39+
40+
- feat: add distributed execution mode and enhance module imports for computed and complex ports
41+
- Updated dependencies
42+
- @badaitech/chaingraph-executor@0.5.5-dev.15
43+
- @badaitech/chaingraph-nodes@0.5.5-dev.15
44+
- @badaitech/chaingraph-types@0.5.5-dev.15
45+
- @badaitech/chaingraph-trpc@0.5.5-dev.15
46+
347
## 0.5.5-dev.14
448

549
### Patch Changes

‎apps/chaingraph-execution-worker/package.json‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
{
22
"name": "@badaitech/chaingraph-execution-worker",
33
"type": "module",
4-
"version": "0.5.5-dev.14",
4+
"version": "0.5.5-dev.18",
55
"private": false,
66
"description": "Chaingraph Execution Worker Service which connected to Kafka and process the flow executions",
77
"license": "BUSL-1.1",

0 commit comments

Comments
 (0)