File tree
8 files changed
+20
-6
lines changed- .github/workflows
- packages
- core-bridge
- test/src
- workflow/src
8 files changed
+20
-6
lines changedLines changed: 3 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
77 | 77 |
| |
78 | 78 |
| |
79 | 79 |
| |
| 80 | + | |
| 81 | + | |
| 82 | + | |
80 | 83 |
| |
81 | 84 |
| |
82 | 85 |
| |
|
Lines changed: 5 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
40 | 40 |
| |
41 | 41 |
| |
42 | 42 |
| |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
43 | 48 |
| |
44 | 49 |
| |
45 | 50 |
| |
|
Lines changed: 3 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
75 | 75 |
| |
76 | 76 |
| |
77 | 77 |
| |
| 78 | + | |
| 79 | + | |
| 80 | + | |
78 | 81 |
| |
79 | 82 |
| |
80 | 83 |
| |
|
Lines changed: 3 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
83 | 83 |
| |
84 | 84 |
| |
85 | 85 |
| |
| 86 | + | |
| 87 | + | |
| 88 | + | |
86 | 89 |
| |
87 | 90 |
| |
88 | 91 |
| |
|
- .cargo/config.toml+6-1
- .github/workflows/per-pr.yml+38-9
- .gitignore+1
- AGENTS.md+73
- client/src/lib.rs+9-5
- client/src/metrics.rs+15-16
- client/src/proxy.rs+2-2
- client/src/raw.rs+8-7
- client/src/retry.rs+77-15
- client/src/worker_registry/mod.rs+4-4
- client/src/workflow_handle/mod.rs+1-1
- core-api/Cargo.toml+8
- core-api/src/envconfig.rs+1.5k
- core-api/src/lib.rs+2
- core-api/src/worker.rs+46-8
- core/Cargo.toml+13-3
- core/src/abstractions.rs+33-4
- core/src/core_tests/workflow_tasks.rs+151-1
- core/src/ephemeral_server/mod.rs+10-3
- core/src/internal_flags.rs+14-14
- core/src/lib.rs+4
- core/src/pollers/poll_buffer.rs+37-64
- core/src/protosext/mod.rs+3-3
- core/src/telemetry/metrics.rs+6-5
- core/src/worker/activities.rs+2-2
- core/src/worker/activities/activity_heartbeat_manager.rs+7-7
- core/src/worker/activities/local_activities.rs+14-13
- core/src/worker/client.rs+48-22
- core/src/worker/mod.rs+15-10
- core/src/worker/nexus.rs+100-73
- core/src/worker/tuner/resource_based.rs+3-2
- core/src/worker/workflow/history_update.rs+8-8
- core/src/worker/workflow/machines/child_workflow_state_machine.rs+1-4
- core/src/worker/workflow/machines/nexus_operation_state_machine.rs+112-20
- core/src/worker/workflow/machines/update_state_machine.rs+1-1
- core/src/worker/workflow/machines/workflow_machines.rs+22-29
- core/src/worker/workflow/managed_run.rs+28-30
- core/src/worker/workflow/mod.rs+191-108
- core/src/worker/workflow/wft_poller.rs+79-30
- core/src/worker/workflow/workflow_stream.rs+33-33
- sdk-core-protos/protos/api_cloud_upstream/.github/workflows/push-to-buf.yml+20
- sdk-core-protos/protos/api_cloud_upstream/CODEOWNERS+6
- sdk-core-protos/protos/api_cloud_upstream/README.md+17-6
- sdk-core-protos/protos/api_cloud_upstream/VERSION+1-1
- sdk-core-protos/protos/api_cloud_upstream/buf.lock+7-2
- sdk-core-protos/protos/api_cloud_upstream/buf.yaml+2
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/request_response.proto+78
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/service.proto+29
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/identity/v1/message.proto+74-32
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/namespace/v1/message.proto+45-15
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/nexus/v1/message.proto+7-1
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/operation/v1/message.proto+3-3
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/region/v1/message.proto+3-3
- sdk-core-protos/protos/local/temporal/sdk/core/nexus/nexus.proto+16-1
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_activation/workflow_activation.proto+3-3
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_commands/workflow_commands.proto+3
- sdk/src/lib.rs+10-14
- sdk/src/workflow_context.rs+24-24
- sdk/src/workflow_context/options.rs+7
- test-utils/src/lib.rs+35-19
- tests/cloud_tests.rs+86
- tests/fuzzy_workflow.rs+23-26
- tests/integ_tests/metrics_tests.rs+2-2
- tests/integ_tests/polling_tests.rs+94-8
- tests/integ_tests/worker_tests.rs+45-2
- tests/integ_tests/worker_versioning_tests.rs+3-3
- tests/integ_tests/workflow_tests.rs+3-55
- tests/integ_tests/workflow_tests/local_activities.rs+1-1
- tests/integ_tests/workflow_tests/nexus.rs+275-10
- tests/main.rs+2-51
- tests/runner.rs+13-1
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
266 | 266 |
| |
267 | 267 |
| |
268 | 268 |
| |
269 |
| - | |
| 269 | + | |
270 | 270 |
| |
271 | 271 |
| |
272 | 272 |
| |
| |||
280 | 280 |
| |
281 | 281 |
| |
282 | 282 |
| |
283 |
| - | |
| 283 | + | |
284 | 284 |
| |
285 | 285 |
| |
286 | 286 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
325 | 325 |
| |
326 | 326 |
| |
327 | 327 |
| |
328 |
| - | |
| 328 | + | |
329 | 329 |
| |
330 | 330 |
| |
331 | 331 |
| |
| |||
496 | 496 |
| |
497 | 497 |
| |
498 | 498 |
| |
499 |
| - | |
| 499 | + | |
500 | 500 |
| |
501 | 501 |
| |
502 | 502 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
195 | 195 |
| |
196 | 196 |
| |
197 | 197 |
| |
198 |
| - | |
| 198 | + | |
199 | 199 |
| |
200 | 200 |
| |
201 | 201 |
| |
|
0 commit comments