The GitHub Actions job "Tests" on airflow.git/backport-60976-v3-1-test has 
failed.
Run started by GitHub user dabla (triggered by dabla).

Head commit for run:
59f07daf88ad072fffa3337eb1d1ce14a9231bc7 / David Blain <[email protected]>
Prevent Triggerer from crashing when a trigger event isn't serializable (#60152)

* refactor: If asend in TriggerRunner comms decoder crashes due to 
NotImplementedError as a trigger event is not serializable, then retry without 
that event and cancel associated trigger

* refactor: Applied some reformatting

* refactor: Fixed some mypy issues

* refactor: Fixed return type of send_changes method

* refactor: Changed imports of trigger events

* refactor: Reformatted trigger job runner

* refactor: Fixed mocking of comms decoder

* refactor: Forgot to add the patched supervisor_builder

* refactor: Changed asserts in test_sync_state_to_supervisor

* refactor: Refactored how state changes are validated

* refactor: Validate events while creating the TriggerStateChanges message

* refactor: Refactored try/except in validate_state_changes to keep mypy happy

* Update airflow-core/src/airflow/jobs/triggerer_job_runner.py

Co-authored-by: Ash Berlin-Taylor <[email protected]>

* refactor: Renamed validate_state_changes method to process_trigger_events

* refactor: Only sanitize invalid trigger events if first attempt fails

* refactor: Should check if msg.events is not None

* refactor: Adapted test_sync_state_to_supervisor so both initial and retry 
call are correctly asserted and bad events are being sanitized

---------

Co-authored-by: Ash Berlin-Taylor <[email protected]>

(cherry picked from commit 0238244413e1b802d2cc6df799c0f2cc16b5f7a7)

Report URL: https://github.com/apache/airflow/actions/runs/21313959402

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to