jscheffl opened a new pull request, #37888:
URL: https://github.com/apache/airflow/pull/37888
This PR is a WIP proposal to fix/resolve the request for feature #37810
NOTE: It is just a code preview, therefore WIP.
Idea:
- Use XCom / task result as `extra` (if not provided in Dataset reference)
- If dataset defines `extra` use this as params
- If task returns a dict, pass this as params
- If task does not return a dict, provide the task name as key, return as
value
- Pass the `extra` to the data triggered DAG as `params`
- If multiple events trigger a DAG, params are merged
Open items:
- Agree on "this is a good idea"
- Documentation
- Is this a noteworthy change? Then add a newsfragment
- Polishing of example(s)
closes: #37810
--
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]
