airflow.example_dags.example_task_state_store_mapped
Example DAG with mapped tasks to demonstrate task state store isolation per map_index.
Attributes
Functions
Return the list of tables to process. |
Module Contents
- airflow.example_dags.example_task_state_store_mapped.TABLES = ['orders', 'customers', 'products'][source]
- airflow.example_dags.example_task_state_store_mapped.get_tables()[source]
Return the list of tables to process.