File tree
3 files changed
+1
-13
lines changed- packages
- client/src
- core-bridge
3 files changed
+1
-13
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
44 | 44 | | |
45 | 45 | | |
46 | 46 | | |
47 | | - | |
48 | | - | |
49 | 47 | | |
50 | 48 | | |
51 | 49 | | |
| |||
59 | 57 | | |
60 | 58 | | |
61 | 59 | | |
62 | | - | |
63 | | - | |
64 | 60 | | |
65 | 61 | | |
66 | 62 | | |
| |||
133 | 129 | | |
134 | 130 | | |
135 | 131 | | |
136 | | - | |
137 | | - | |
138 | 132 | | |
139 | 133 | | |
140 | 134 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
457 | 457 | | |
458 | 458 | | |
459 | 459 | | |
460 | | - | |
461 | | - | |
462 | 460 | | |
463 | 461 | | |
464 | 462 | | |
| |||
629 | 627 | | |
630 | 628 | | |
631 | 629 | | |
632 | | - | |
633 | | - | |
634 | 630 | | |
635 | 631 | | |
636 | 632 | | |
| |||
663 | 659 | | |
664 | 660 | | |
665 | 661 | | |
666 | | - | |
667 | | - | |
668 | 662 | | |
669 | 663 | | |
670 | 664 | | |
| |||
- .cargo/config.toml+1-6
- .github/workflows/per-pr.yml+9-38
- .gitignore-1
- AGENTS.md-73
- client/src/lib.rs+5-9
- client/src/metrics.rs+16-15
- client/src/proxy.rs+2-2
- client/src/raw.rs+7-8
- client/src/retry.rs+15-77
- 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+8-46
- core/Cargo.toml+3-13
- core/src/abstractions.rs+4-33
- core/src/core_tests/workflow_tasks.rs+1-151
- core/src/ephemeral_server/mod.rs+3-10
- core/src/internal_flags.rs+14-14
- core/src/lib.rs-4
- core/src/pollers/poll_buffer.rs+64-37
- core/src/protosext/mod.rs+3-3
- core/src/telemetry/metrics.rs+5-6
- core/src/worker/activities.rs+2-2
- core/src/worker/activities/activity_heartbeat_manager.rs+7-7
- core/src/worker/activities/local_activities.rs+13-14
- core/src/worker/client.rs+22-48
- core/src/worker/mod.rs+10-15
- core/src/worker/nexus.rs+73-100
- core/src/worker/tuner/resource_based.rs+2-3
- core/src/worker/workflow/history_update.rs+8-8
- core/src/worker/workflow/machines/child_workflow_state_machine.rs+4-1
- core/src/worker/workflow/machines/nexus_operation_state_machine.rs+20-112
- core/src/worker/workflow/machines/update_state_machine.rs+1-1
- core/src/worker/workflow/machines/workflow_machines.rs+29-22
- core/src/worker/workflow/managed_run.rs+30-28
- core/src/worker/workflow/mod.rs+108-191
- core/src/worker/workflow/wft_poller.rs+30-79
- 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+6-17
- sdk-core-protos/protos/api_cloud_upstream/VERSION+1-1
- sdk-core-protos/protos/api_cloud_upstream/buf.lock+2-7
- 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+32-74
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/namespace/v1/message.proto+15-45
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/nexus/v1/message.proto+1-7
- 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+1-16
- 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+14-10
- sdk/src/workflow_context.rs+24-24
- sdk/src/workflow_context/options.rs-7
- test-utils/src/lib.rs+19-35
- tests/cloud_tests.rs-86
- tests/fuzzy_workflow.rs+26-23
- tests/integ_tests/metrics_tests.rs+2-2
- tests/integ_tests/polling_tests.rs+8-94
- tests/integ_tests/worker_tests.rs+2-45
- tests/integ_tests/worker_versioning_tests.rs+3-3
- tests/integ_tests/workflow_tests.rs+55-3
- tests/integ_tests/workflow_tests/local_activities.rs+1-1
- tests/integ_tests/workflow_tests/nexus.rs+10-275
- tests/main.rs+51-2
- tests/runner.rs+1-13
0 commit comments