Airflow Dagster - sgml/signature GitHub Wiki

docker-compose

Dagster

Bash script

Slack

+-------------------+       +-------------------+
|                   |       |                   |
|   Apache Airflow  |       |      Slack        |
|                   |       |                   |
+-------------------+       +-------------------+
        |                           |
        |                           |
        |                           |
        v                           v
+-------------------+       +-------------------+
|                   |       |                   |
|   DAG Execution   | ----> |   Slack Channel   |
|                   |       |                   |
+-------------------+       +-------------------+

Alembic initdb/createdb/upgradedb

LocalExecutor

Parallelism / Task Dependencies

Network Connections

Celery

Persistent Volumes

pip install

Permissions

Roles

XCom

Variables

Sensors

Operators

Upstream/Downstream Iteration

Logging

Providers

Schema Models

Exceptions

Testing

Concepts

Backfilling

Best Practices

Scheduler

CLI

ETL

Config

Dynamic Tasks / Task IDs

Pattern

  • Set an empty array as a global
  • Populate it using a method not bound to a task
  • Create a method that returns a PythonOperator
  • Call that method while looping through the populated array

Sample Code

Error Handling

Troubleshooting

Sample Projects

Blogs

volumes:
    airflowlogs:/usr/local/airflow/log #Add a named volume to the webserver and scheduler section of docker-compose map to fix Errno 13

Boilerplate

Email Configuration

References

⚠️ **GitHub.com Fallback** ⚠️