Ajay9704 opened a new pull request, #62278:
URL: https://github.com/apache/airflow/pull/62278
This PR ensures that when deferrable=True, the operator correctly fails when
a Cloud Run Job is cancelled, matching the behavior of non-deferrable mode.
Modified files:
providers/google/src/airflow/providers/google/cloud/triggers/cloud_run.py -
CloudRunJobFinishedTrigger.run()
providers/google/src/airflow/providers/google/cloud/operators/cloud_run.py -
CloudRunExecuteJobOperator.execute_complete()
providers/google/tests/unit/google/cloud/operators/test_cloud_run.py -
Tests for cancelled/failed scenarios
providers/google/tests/unit/google/cloud/triggers/test_cloud_run.py -
Tests for execution details
Changes include:
Trigger now includes task_count, succeeded_count, failed_count from
operation response
Operator validates execution status in execute_complete() method
Raises AirflowException when tasks are incomplete (cancelled job)
Raises AirflowException when tasks failed (failed_count > 0)
Comprehensive test coverage for cancelled, failed, and successful
scenarios
Closes #57791
AI Disclosure:
Yes
--
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]
