uranusjr opened a new pull request, #49345:
URL: https://github.com/apache/airflow/pull/49345
[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
--
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]
