The GitHub Actions job "Tests" on
airflow.git/forward-trigger-event-to-asset-event has failed.
Run started by GitHub user uranusjr (triggered by uranusjr).
Head commit for run:
99d789fbc036d7e2fb839a90194aff56f6dd7cbc / Tzu-ping Chung <uranu...@gmail.com>
Include trigger event payload in asset event
[AIP-82] allows triggering an asset from the triggerer with a trigger
event. A trigger event can contain extra information, but we did not
forward it to the asset event; the trigger event is simply lost.
This adds a field 'payload' on the triggered asset event's extra that
holds the source trigger event's content. Example to retrieve the
trigger event:
a = Asset(name="a", watchers=[AssetWatcher(...)])
@task
def process_message(triggering_asset_events):
for event in triggering_asset_events[a]:
print(event.extra["payload"]) # TriggerEvent payload.
[AIP-82]: https://cwiki.apache.org/confluence/x/egzOEg
Report URL: https://github.com/apache/airflow/actions/runs/14490930564
With regards,
GitHub Actions via GitBox
---------------------------------------------------------------------
To unsubscribe, e-mail: jobs-unsubscr...@airflow.apache.org
For additional commands, e-mail: jobs-h...@airflow.apache.org
