Example DAG demonstrating the usage of XComs.
Module Contents
Functions
push([ti])
|
Pushes an XCom without a specific target |
push_by_returning()
|
Pushes an XCom without a specific target, just by returning it |
puller(pulled_value_2[, ti])
|
Pull all previously pushed XComs and check if the pushed values match the pulled values. |
pull_value_from_bash_push([ti])
|
|
Attributes
-
airflow.example_dags.example_xcom.value_1 = [1, 2, 3][source]
-
airflow.example_dags.example_xcom.value_2[source]
-
airflow.example_dags.example_xcom.push(ti=None)[source]
Pushes an XCom without a specific target
-
airflow.example_dags.example_xcom.push_by_returning()[source]
Pushes an XCom without a specific target, just by returning it
-
airflow.example_dags.example_xcom.puller(pulled_value_2, ti=None)[source]
Pull all previously pushed XComs and check if the pushed values match the pulled values.
-
airflow.example_dags.example_xcom.pull_value_from_bash_push(ti=None)[source]
-
airflow.example_dags.example_xcom.bash_push[source]