Learn
idempotency
8 registry resources · 5 tutorials, 1 skill · roadmap: Data Quality, Orchestration, Data Processing, Reliability, Streaming
What this topic covers
DE//AGENT currently lists 8 resources under idempotency: 5 tutorials, 1 skill, 1 runbook. Everything below is derived from the live registry — counts, capabilities, verification state and security posture come from the curated records, never from marketing copy.
Also present: 1 pattern.
What you can learn here
Documented learning objectives across these resources:
- Make every task safe to re-run — via Airflow DAG Reviewer
- Choose retries and timeouts deliberately — via Airflow DAG Reviewer
- Predict what a backfill will do before running it — via Airflow DAG Reviewer
- Count duplicates per key with one GROUP BY query — via Deduplicate records without rewriting the table
- Correlate the first duplicate date with a deploy — via Deduplicate records without rewriting the table
- Rewrite affected partitions instead of the whole table — via Deduplicate records without rewriting the table
- Apply the idempotency test to every task in a DAG — via Review a DAG for idempotency and retry safety
- Justify retry, timeout and concurrency settings per task — via Review a DAG for idempotency and retry safety
9 more objectives live on the individual resource pages.
Where this fits in the learning roadmap
These resources map to stages: Data Quality (2), Orchestration (2), Data Processing (2), Reliability (1), Streaming (1). Follow the four-phase roadmap to place this topic inside a progression instead of learning it in isolation.
Compare the registry's options
Every entry, its shape and its trust state — sorted by the registry's composite score. This table is the honest version of a marketing comparison: no sponsored placements, no unverifiable claims.
| Resource | Type | Difficulty | Verification | Score |
|---|---|---|---|---|
| Airflow DAG Reviewer | Skill | intermediate | community flags | 39.5 |
| Duplicate records | Runbook | intermediate | community flags | 35.25 |
| Idempotent Partition Overwrite | Pattern | beginner | community | 34.75 |
| Deduplicate records without rewriting the table | Tutorial | beginner | community | 34.15 |
| Review a DAG for idempotency and retry safety | Tutorial | beginner | community | 34.15 |
| Capstone — the batch pipeline checklist | Tutorial | intermediate | community | 34.15 |
| Idempotency and reruns — make every task safe to run twice | Tutorial | intermediate | community | 34.15 |
| Make the sink idempotent so replays never duplicate rows | Tutorial | intermediate | community | 34.15 |
How scores are computed: source quality score.
Where to start
Highest composite score first:
- Airflow DAG Reviewer score 39.5 — intermediate
- Duplicate records score 35.25 — intermediate
- Idempotent Partition Overwrite score 34.75 — beginner
Scores rank provenance, completeness and trust — read how verification works before adopting anything.
Good fits
Start here if you're new: Idempotent Partition Overwrite, Deduplicate records without rewriting the table, Review a DAG for idempotency and retry safety.
Cautions and limitations
Security-flagged entries: Airflow DAG Reviewer (1 flag), Duplicate records (1 flag). Flags mean the record declares capabilities like credential use or write access — read the security posture on each page before connecting.
Known limits: Streaming writes with no partition boundary (use MERGE/upsert instead) (Idempotent Partition Overwrite)
Production use cases
- Airflow DAG Reviewer — Checks a DAG for non-idempotent tasks, unsafe retries, missing catchup policy, ambiguous catchup/backfill semantics and unbounded concurrency. details
- Duplicate records — Row counts are inflated and metrics double-counted after a retry, a fan-out join or a backfill. details
- Deduplicate records without rewriting the table — Row counts are inflated and revenue double-counted after a retry or a fan-out join. Work the duplicate-records runbook: find the first duplicate date, correlate it with a deploy, d… details
- Review a DAG for idempotency and retry safety — Walk the Pipeline Reviewer's four-step pass over a DAG: apply the idempotency test to every task, check retry, timeout and concurrency settings, predict backfill behaviour, and pro… details
Install and inspect
Real install commands from the registry — read the source before running any of them:
npx de-agent-platform add airflow-dag-reviewerAirflow DAG Reviewer — review first
Further study
Adjacent topics: tutorial (5 shared), data-quality (2 shared), batch (2 shared), partitions (2 shared), dag (2 shared), duplicates (2 shared).
Study path: the roadmap places this topic in a progression · the scoring model explains the numbers · the trust rule catalog shows every security check these entries passed through.
Full resource list
| Resource | Type | Score |
|---|---|---|
| Airflow DAG Reviewer | Skill | 39.5 |
| Duplicate records | Runbook | 35.25 |
| Idempotent Partition Overwrite | Pattern | 34.75 |
| Deduplicate records without rewriting the table | Tutorial | 34.15 |
| Review a DAG for idempotency and retry safety | Tutorial | 34.15 |
| Capstone — the batch pipeline checklist | Tutorial | 34.15 |
| Idempotency and reruns — make every task safe to run twice | Tutorial | 34.15 |
| Make the sink idempotent so replays never duplicate rows | Tutorial | 34.15 |