Start studying
Module 13 · Data Engineering Basics Module contents
Module 13  ·  Card 12 / 13intermediate

Pipeline Orchestration

Pipeline orchestration schedules and coordinates the steps of data pipelines so they run in the right order.

Steps are arranged as a graph of dependencies, so a step runs only after the steps it needs have finished.

For example, the sales report waits for both the orders load and the currency rates load to complete.

Orchestrators retry failed steps, send alerts and record each run, so problems are found before reports go out.

Apache Airflow is a widely used orchestrator, alongside tools such as Dagster and Prefect.

Learn in depth ↓
Module 13 · Data Engineering Basics · 13 concepts
In depth  /  15 lines

Pipeline Orchestration, in more detail

Orchestration turns a set of separate scripts into a dependable system.

Without it, jobs run on timers and hope that whatever they depend on has finished.

With it, each step knows what it needs and runs only when those inputs are ready.

Pipelines are described as a directed acyclic graph of tasks, the same shape as a causal DAG.

Each arrow means one task must finish before the next starts, and no loops are allowed.

The orchestrator schedules runs, such as every night at 2am, or triggers them when new data arrives.

Failed tasks are retried a set number of times before an alert goes out.

Every run is logged, with timings and outcomes, so slow or failing steps are easy to spot.

Backfilling reruns a pipeline for past dates, such as rebuilding last month after a bug fix.

Tasks should be idempotent, so retries and backfills give the same result as a single clean run.

Apache Airflow describes pipelines in Python code, which suits teams that already write Python.

Other tools, such as Dagster and Prefect, focus more on the data each task produces.

The orchestrator coordinates the work but usually leaves the heavy lifting to other systems, such as the warehouse.

In practice, a clear failure alert at 3am beats a wrong report discovered at 9am.

The usual mistake is running heavy data processing inside the orchestrator itself, which overloads it.

Want the full technical article? Wikipedia ↗
Test yourself

One question on this card. Every option explains itself once you pick, right or wrong.

Question 1
A daily sales report sometimes runs before the orders load has finished, showing half a day of sales. What fixes this?
Data Engineering Basics

13 concepts in this module, then a graded test with every answer explained.

Study this module →
↑↓ move↵ openesc close