File tree
8 files changed
+20
-6
lines changed- .github/workflows
- packages
- core-bridge
- test/src
- workflow/src
8 files changed
+20
-6
lines changed| 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 | | |
| |||
| 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 | | |
| |||
| 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 | | |
| |||
| 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
| 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 | | |
| |||
| 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 | | |
| |||
| 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