Revanth14 opened a new pull request, #67626:
URL: https://github.com/apache/airflow/pull/67626
fixes: #67616
`DbtCloudRunJobOperator` was computing serialized trigger deadlines with
`time.monotonic()`. Those values are passed from the worker to
`DbtCloudRunJobTrigger` and may be deserialized in a different triggerer
process, container, pod, or node, a common setup in Kubernetes and Astronomer
deployments.
Since monotonic clocks are only meaningful within the local system,
comparing a worker-computed monotonic deadline against the triggerer's
monotonic clock can cause immediate false timeouts regardless of the configured
timeout value.
This replaces the serialized `end_time` and `execution_deadline` values with
wall-clock `time.time()` and updates the trigger comparison accordingly.
Tests:
- Added `test_dbt_run_job_trigger_uses_wall_clock_end_time` to assert the
trigger compares `end_time` against `time.time()`, not `time.monotonic()`,
even when monotonic time would produce an immediate false timeout.
- `uv run pytest
providers/dbt/cloud/tests/unit/dbt/cloud/triggers/test_dbt.py
providers/dbt/cloud/tests/unit/dbt/cloud/operators/test_dbt.py -q`
- 82 passed
##### Was generative AI tooling used to co-author this PR?
- [X] Yes (OpenAI Codex)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
