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