Implementing Dynamic Task Mapping in Apache Airflow
Learn how to use Airflow's .expand() to fan out one task definition over a runtime-resolved list, with setup steps, UI verification checks, and recovery options for failed mapped instances.
ReadMeFeed / Community knowledge
Real questions. Useful conversations. Find the people who know your stack.
Learn how to use Airflow's .expand() to fan out one task definition over a runtime-resolved list, with setup steps, UI verification checks, and recovery options for failed mapped instances.
Learn how the @task decorator turns Python functions into tasks with automatic XCom handling, making DAGs cleaner and easier to maintain.