Summary

• add scheduler unit coverage that distributed queue dispatch includes queued runtime params in coordinator tasks
• add shared-nothing integration coverage for queued root DAG runtime params reaching worker execution
• extend the distributed integration fixture with a params-aware enqueue helper

Testing

• go test ./internal/service/scheduler -run TestDAGExecutor_DistributedRetryPassesQueuedParams -count=1
• go test ./internal/service/scheduler -run TestDAGExecutor -count=1
• go test ./internal/intg/distr -run TestParams -count=1
• go test ./internal/intg/distr -run 'TestExecution_QueueLifecycle/queueItemRemovedAfterSuccess' -count=1

Summary by cubic

Add tests to verify queued runtime params propagate end-to-end in distributed runs, including retries. Adds a params-aware enqueue helper and asserts params flow into coordinator tasks, DAGRun status, and worker outputs.

^{Written for commit 5b7a51d. Summary will update on new commits.}

Summary by CodeRabbit

• Tests
  • Enhanced test coverage for distributed DAG execution, including parameterized queue operations and runtime parameter handling in queued runs.
  • Added distributed retry test to verify parameters are correctly preserved through retry operations.