goyaladitay11 commented on PR #74225:
URL: https://github.com/apache/airflow/pull/74225#issuecomment-6020562267

   Thanks @zozo123! Both items have been addressed:
   
   Permanent Query Error Handling in Trigger: Added _is_permanent_error() to 
detect permanent query failures (TABLE_OR_VIEW_NOT_FOUND, PERMISSION_DENIED, 
ACCESS_DENIED, etc.). The trigger now immediately yields an error TriggerEvent 
and exits on permanent failures instead of retrying until timeout, preserving 
retries only for transient errors. Added unit tests for missing table, 
permission denied, and transient error retry.
   Restore Baseline Version on Resume: In execute_complete(), 
self._baseline_version is now restored from event["baseline_version"] before 
calling _push_provenance(), ensuring deferred enrollment provenance accurately 
reflects the baseline version after task resume. Added a unit test verifying 
this restoration.
   All 48 unit tests passing and Ruff formatting clean. Ready for your 
re-review and approval!


-- 
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]

Reply via email to