1 file changed
+1
-1
lines changed- .github/workflows/per-pr.yml+7-1
- Cargo.toml+6-6
- client/Cargo.toml+7-5
- client/src/lib.rs+45-17
- client/src/metrics.rs+3-3
- client/src/proxy.rs+17-12
- client/src/raw.rs+147-83
- client/src/retry.rs+111-65
- client/src/workflow_handle/mod.rs+1-2
- core-api/src/telemetry.rs+1
- core/Cargo.toml+11-11
- core/src/abstractions.rs+5-6
- core/src/core_tests/activity_tasks.rs+1-1
- core/src/core_tests/determinism.rs+1-1
- core/src/core_tests/local_activities.rs+2-2
- core/src/core_tests/queries.rs+8-4
- core/src/core_tests/updates.rs+2-2
- core/src/core_tests/workflow_cancels.rs+3-3
- core/src/core_tests/workflow_tasks.rs+142-75
- core/src/ephemeral_server/mod.rs+19-7
- core/src/internal_flags.rs+17-7
- core/src/pollers/poll_buffer.rs+1-10
- core/src/protosext/mod.rs+3-1
- core/src/retry_logic.rs+1-4
- core/src/telemetry/metrics.rs+69-1
- core/src/telemetry/mod.rs-8
- core/src/telemetry/otel.rs+15-11
- core/src/test_help/mod.rs+3-3
- core/src/worker/activities.rs+20-10
- core/src/worker/activities/activity_task_poller_stream.rs+11
- core/src/worker/activities/local_activities.rs+52-20
- core/src/worker/client/mocks.rs+2-2
- core/src/worker/mod.rs+11-14
- core/src/worker/slot_provider.rs+4-3
- core/src/worker/tuner/resource_based.rs+1-1
- core/src/worker/workflow/driven_workflow.rs+29-3
- core/src/worker/workflow/history_update.rs+2-2
- core/src/worker/workflow/machines/activity_state_machine.rs+24-8
- core/src/worker/workflow/machines/cancel_external_state_machine.rs+1-1
- core/src/worker/workflow/machines/cancel_workflow_state_machine.rs+1-1
- core/src/worker/workflow/machines/child_workflow_state_machine.rs+7-7
- core/src/worker/workflow/machines/local_activity_state_machine.rs+11-16
- core/src/worker/workflow/machines/mod.rs+1-1
- core/src/worker/workflow/machines/patch_state_machine.rs+3-2
- core/src/worker/workflow/machines/signal_external_state_machine.rs+1-1
- core/src/worker/workflow/machines/timer_state_machine.rs+1-1
- core/src/worker/workflow/machines/update_state_machine.rs+4-4
- core/src/worker/workflow/machines/workflow_machines.rs+38-22
- core/src/worker/workflow/machines/workflow_task_state_machine.rs+3-3
- core/src/worker/workflow/managed_run.rs+234-18
- core/src/worker/workflow/mod.rs+34-40
- core/src/worker/workflow/workflow_stream.rs+3-3
- docker/docker-compose-telem.yaml+4-4
- etc/otel-collector-config.yaml+12-9
- fsm/rustfsm_procmacro/src/lib.rs+2-2
- sdk-core-protos/Cargo.toml+4-3
- sdk-core-protos/build.rs+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/activity_result/activity_result.proto+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/activity_task/activity_task.proto+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/child_workflow/child_workflow.proto+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/common/common.proto+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/core_interface.proto+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/external_data/external_data.proto+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_activation/workflow_activation.proto+32-13
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_commands/workflow_commands.proto+1-1
- sdk-core-protos/protos/local/temporal/sdk/core/workflow_completion/workflow_completion.proto+1-1
- sdk-core-protos/src/history_builder.rs+8-1
- sdk-core-protos/src/lib.rs+119-67
- sdk/Cargo.toml+1-1
- sdk/src/activity_context.rs+3-4
- sdk/src/lib.rs+34-6
- sdk/src/workflow_context.rs+15-3
- sdk/src/workflow_future.rs+28-8
- test-utils/src/canned_histories.rs+1-1
- test-utils/src/lib.rs+4-3
- tests/integ_tests/client_tests.rs+264-7
- tests/integ_tests/heartbeat_tests.rs+1-1
- tests/integ_tests/metrics_tests.rs+191-5
- tests/integ_tests/queries_tests.rs+95-62
- tests/integ_tests/update_tests.rs+16-9
- tests/integ_tests/visibility_tests.rs+1-1
- tests/integ_tests/worker_tests.rs+82-1
- tests/integ_tests/workflow_tests.rs+2-1
- tests/integ_tests/workflow_tests/activities.rs+90-8
- tests/integ_tests/workflow_tests/local_activities.rs+81-2
- tests/integ_tests/workflow_tests/resets.rs+139-4
- tests/integ_tests/workflow_tests/upsert_search_attrs.rs+43-28
- tests/main.rs+28-19
- tests/runner.rs+7-2
0 commit comments