File tree
13 files changed
+526
-211
lines changed- packages
- core-bridge
- src
- ts
- test/src
- worker/src
13 files changed
+526
-211
lines changedLines changed: 48 additions & 19 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
- .github/workflows/per-pr.yml+28
- Cargo.toml+2-1
- client/Cargo.toml+1-1
- client/src/lib.rs+2-2
- client/src/metrics.rs+7-2
- client/src/raw.rs+14
- core-api/Cargo.toml+1-1
- core-api/src/telemetry.rs+37-3
- core-api/src/telemetry/metrics.rs+26
- core-api/src/worker.rs+2
- core/Cargo.toml+4-4
- core/src/abstractions.rs+1-1
- core/src/core_tests/activity_tasks.rs+66-16
- core/src/core_tests/child_workflows.rs+65-8
- core/src/core_tests/local_activities.rs+6-16
- core/src/core_tests/queries.rs+68-68
- core/src/core_tests/workers.rs+2-6
- core/src/core_tests/workflow_tasks.rs+53-24
- core/src/ephemeral_server/mod.rs+1-1
- core/src/telemetry/log_export.rs+1-1
- core/src/telemetry/metrics.rs+32-21
- core/src/telemetry/mod.rs+8-1
- core/src/telemetry/otel.rs+103-136
- core/src/telemetry/prometheus_server.rs-3
- core/src/test_help/mod.rs+2-1
- core/src/worker/mod.rs+12-4
- core/src/worker/workflow/driven_workflow.rs+7-2
- core/src/worker/workflow/machines/activity_state_machine.rs+3-8
- core/src/worker/workflow/machines/cancel_external_state_machine.rs+2-7
- core/src/worker/workflow/machines/cancel_workflow_state_machine.rs+2-10
- core/src/worker/workflow/machines/child_workflow_state_machine.rs+2-10
- core/src/worker/workflow/machines/complete_workflow_state_machine.rs+12-25
- core/src/worker/workflow/machines/continue_as_new_workflow_state_machine.rs+2-7
- core/src/worker/workflow/machines/fail_workflow_state_machine.rs+4-9
- core/src/worker/workflow/machines/local_activity_state_machine.rs-39
- core/src/worker/workflow/machines/mod.rs+1-2
- core/src/worker/workflow/machines/modify_workflow_properties_state_machine.rs+6-11
- core/src/worker/workflow/machines/patch_state_machine.rs+9-15
- core/src/worker/workflow/machines/signal_external_state_machine.rs+3-7
- core/src/worker/workflow/machines/timer_state_machine.rs+11-16
- core/src/worker/workflow/machines/upsert_search_attributes_state_machine.rs+8-14
- core/src/worker/workflow/machines/workflow_machines.rs+79-60
- core/src/worker/workflow/managed_run.rs+65-35
- core/src/worker/workflow/mod.rs+54-32
- core/src/worker/workflow/run_cache.rs+17-3
- core/src/worker/workflow/workflow_stream.rs+22-4
- docker/docker-compose-ci.yaml+25
- etc/otel-collector-ci.yaml+36
- etc/otel-collector-config.yaml+3-3
- etc/prometheus.yaml+1-1
- sdk-core-protos/Cargo.toml+1-1
- sdk-core-protos/protos/api_cloud_upstream/VERSION+1-1
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/account/v1/message.proto+46
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/request_response.proto+254-5
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/cloudservice/v1/service.proto+108-2
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/identity/v1/message.proto+94-15
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/namespace/v1/message.proto+102-4
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/nexus/v1/message.proto+84
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/operation/v1/message.proto+25-10
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/region/v1/message.proto+14-1
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/resource/v1/message.proto+25
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/sink/v1/message.proto+41
- sdk-core-protos/protos/api_cloud_upstream/temporal/api/cloud/usage/v1/message.proto+59
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_activation/workflow_activation.proto+3
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_commands/workflow_commands.proto+10-8
- sdk-core-protos/src/lib.rs+125-11
- sdk/Cargo.toml+1-1
- sdk/src/lib.rs+4-5
- sdk/src/workflow_context.rs+54-34
- sdk/src/workflow_context/options.rs+130-73
- sdk/src/workflow_future.rs+91-96
- test-utils/Cargo.toml+2-1
- test-utils/src/lib.rs+18-1
- tests/integ_tests/heartbeat_tests.rs+1
- tests/integ_tests/metrics_tests.rs+237-21
- tests/integ_tests/polling_tests.rs+2
- tests/integ_tests/queries_tests.rs+7-12
- tests/integ_tests/update_tests.rs+3-6
- tests/integ_tests/visibility_tests.rs+1
- tests/integ_tests/workflow_tests.rs+125-97
- tests/integ_tests/workflow_tests/timers.rs+1
0 commit comments