josh-fell commented on a change in pull request #16866:
URL: https://github.com/apache/airflow/pull/16866#discussion_r687325009
##########
File path: airflow/example_dags/example_xcom.py
##########
@@ -78,6 +104,14 @@ def puller(**kwargs):
pull = PythonOperator(
task_id='puller',
python_callable=puller,
+ op_kwargs={
+ 'pulled_value_1': push1.output['value from pusher 1'],
+ 'pulled_value_3': push2.output,
+ },
Review comment:
@ephraimbuddy @ashb @uranusjr What do you think about creating a new
example DAG that strictly shows `XCom` push/pull with the Taskflow API? I agree
with Ephraim and feel we should have an example for Taskflow API here -- albeit
the original thought was to demonstrate using the `get_current_context()`
method -- especially if see (or want) the community to adopt this style.
(@ephraimbuddy @uranusjr love to get your thoughts on showcasing that method as
well especially with some concerns on blind copy/paste that I agree with @ashb).
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
