uranusjr commented on issue #51711: URL: https://github.com/apache/airflow/issues/51711#issuecomment-4149498083
Implementation plan * New field on SDK operator `returns_dag_result: bool` (defaults to False) to indicate this task emits results for dag. * Decorator `@result` to mark an XCom as the dag’s result. Used _on top of_ `@task`. When used, set `returns_dag_result` to True (on the operator). * Also `dag.add_result` to use with classic operators (e.g. `dag.add_result(op.output)`) * In both cases, the XCom must be a PlainXComArg of `return_value`. * On XComModel, add a new column `dag_result: bool` (defaults to False) * When a task pushes XCom at runtime, set `dag_result=True` if it’s marked as a dag result. * In the `wait` API, if `results` is not set, return the dag results as specified. -- 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]
