1 file changed
+1
-1
lines changed- .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
0 commit comments