2 files changed
+4
-4
lines changed- .cargo/config.toml+7-1
- .cargo/multi-worker-manual-test+15
- .github/workflows/per-pr.yml+1-1
- .gitignore+6-1
- client/src/lib.rs+85-7
- client/src/raw.rs+85-13
- client/src/retry.rs+38-4
- core-api/src/worker.rs+77-41
- core/Cargo.toml+6-1
- core/src/core_tests/activity_tasks.rs+7-6
- core/src/core_tests/mod.rs+4-4
- core/src/core_tests/workers.rs+3-3
- core/src/core_tests/workflow_tasks.rs+23-19
- core/src/pollers/mod.rs+1-1
- core/src/pollers/poll_buffer.rs+522-164
- core/src/replay/mod.rs+3-3
- core/src/telemetry/otel.rs+12-14
- core/src/test_help/mod.rs+2-2
- core/src/worker/activities.rs+25-15
- core/src/worker/activities/local_activities.rs+1
- core/src/worker/client.rs+84-14
- core/src/worker/client/mocks.rs+3-3
- core/src/worker/mod.rs+83-84
- core/src/worker/workflow/machines/nexus_operation_state_machine.rs+1
- core/src/worker/workflow/machines/transition_coverage.rs+1-2
- core/src/worker/workflow/managed_run.rs+4-2
- core/src/worker/workflow/mod.rs+6
- core/src/worker/workflow/wft_poller.rs+126-4
- docker/docker-compose-telem.yaml+1
- etc/prometheus.yaml+6-2
- sdk-core-protos/protos/api_upstream/Makefile+2-2
- sdk-core-protos/protos/api_upstream/openapi/openapiv2.json+2.3k-971
- sdk-core-protos/protos/api_upstream/openapi/openapiv3.yaml+2.3k-927
- sdk-core-protos/protos/api_upstream/temporal/api/batch/v1/message.proto+23
- sdk-core-protos/protos/api_upstream/temporal/api/command/v1/message.proto+6
- sdk-core-protos/protos/api_upstream/temporal/api/common/v1/message.proto+34
- sdk-core-protos/protos/api_upstream/temporal/api/deployment/v1/message.proto+163
- sdk-core-protos/protos/api_upstream/temporal/api/enums/v1/deployment.proto+47
- sdk-core-protos/protos/api_upstream/temporal/api/enums/v1/failed_cause.proto+2
- sdk-core-protos/protos/api_upstream/temporal/api/enums/v1/nexus.proto+42
- sdk-core-protos/protos/api_upstream/temporal/api/enums/v1/workflow.proto+36-17
- sdk-core-protos/protos/api_upstream/temporal/api/failure/v1/message.proto+7
- sdk-core-protos/protos/api_upstream/temporal/api/history/v1/message.proto+35-1
- sdk-core-protos/protos/api_upstream/temporal/api/nexus/v1/message.proto+10
- sdk-core-protos/protos/api_upstream/temporal/api/taskqueue/v1/message.proto+46-2
- sdk-core-protos/protos/api_upstream/temporal/api/workflow/v1/message.proto+98-12
- sdk-core-protos/protos/api_upstream/temporal/api/workflowservice/v1/request_response.proto+337-84
- sdk-core-protos/protos/api_upstream/temporal/api/workflowservice/v1/service.proto+154-42
- sdk-core-protos/protos/local/temporal/sdk/core/activity_task/activity_task.proto+2
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_activation/workflow_activation.proto+13
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_commands/workflow_commands.proto+5-1
- sdk-core-protos/src/lib.rs+6-11
- sdk/src/activity_context.rs+5
- sdk/src/lib.rs+9-11
- sdk/src/workflow_context.rs+22-6
- sdk/src/workflow_context/options.rs+8-1
- sdk/src/workflow_future.rs+10-23
- test-utils/src/lib.rs+45-8
- tests/heavy_tests.rs+127-7
- tests/integ_tests/client_tests.rs+2-8
- tests/integ_tests/metrics_tests.rs+25-43
- tests/integ_tests/worker_tests.rs+6-2
- tests/integ_tests/workflow_tests.rs+11-5
- tests/integ_tests/workflow_tests/child_workflows.rs+13-1
- tests/integ_tests/workflow_tests/nexus.rs+4
- tests/integ_tests/workflow_tests/priority.rs+112
- tests/integ_tests/workflow_tests/stickyness.rs+3-2
- tests/manual_tests.rs+430
- tests/runner.rs+19-2
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
10 | 10 |
| |
11 | 11 |
| |
12 | 12 |
| |
13 |
| - | |
| 13 | + | |
14 | 14 |
| |
15 | 15 |
| |
16 | 16 |
| |
| |||
523 | 523 |
| |
524 | 524 |
| |
525 | 525 |
| |
526 |
| - | |
527 |
| - | |
| 526 | + | |
| 527 | + | |
528 | 528 |
| |
529 | 529 |
| |
530 | 530 |
| |
|
0 commit comments