api-pipeline
Skill3 starsChanged 31 days agoMITView on GitHub
Designs and reviews reliable API-to-analytics ingestion pipelines with architecture-first plans for extraction, state, schemas, security, and operations. Use when planning or implementing ingestion from REST, GraphQL, webhook, or third-party APIs.
In this repository24 other files it gives its agents.
- analytics-requirementsSkill
- bi-modelSkill
- build-modelSkill
- data-model-reviewSkill
- data-profileSkill
- data-quality-investigationSkill
- dbt-healthSkill
- explain-data-codeSkill
- freshness-investigationSkill
- incremental-modelSkill
- metric-definitionSkill
- migration-planSkill
- model-documentationSkill
- model-testsSkill
- project-profileSkill
- pr-reviewSkill
- refactor-modelSkill
- rename-modelSkill
- semantic-layerSkill
- source-setupSkill
- sql-reviewSkill
- trace-lineageSkill
- validate-dbtSkill
- yaml-maintenanceSkill
The file
We split this skill into the rules it gives an agent
11 rules. About 0 are common, 11 are distinctive, and 0 are very specific to this project.
≈0
Common · estimate
Many files like this have a rule of this kind.
≈11
Distinctive · estimate
This author's own choices. Worth a look.
0
Very specific
Tied to their project's names, files or tools. Probably skip.
- Common
- Distinctive
- Very specific
- Distinctive: line 17
Use before implementation when API behavior and operational guarantees are incomplete.
- Distinctive: line 28
Default silently to Work mode and produce an implementation-ready architecture and phased plan.
- Distinctive: line 56
Prefer a server-provided cursor/change token over timestamps.
- Distinctive: line 57
Use timestamp watermarks only with stable semantics and an overlap/dedup strategy.
- Distinctive: line 58
Use webhooks for latency, paired with polling/reconciliation for loss recovery.
- Distinctive: line 81
Do not include credential values or runnable calls containing secrets.
- Distinctive: line 85
Test pagination boundaries, empty pages, duplicate pages, and changing datasets.
- Distinctive: line 86
Test timeout, 429, 5xx, invalid payload, expired auth, restart, and checkpoint failure.
- Distinctive: line 88
Verify idempotent replay, overlap deduplication, delete handling, schema drift, and backfill isolation.
- Distinctive: line 95
Never make test calls against production or consume quota without approval.
- Distinctive: line 100
Do not assume credentials exist, APIs are stable, docs are current, ordering is deterministic, timestamps are reliable cursors, retries are …
≈ “Common” is an estimate: at least 1 in 5 of the 350,495 skill files we read have a rule of the same kind, not the same words. “Very specific” is our guess from the words: it names a file, a command, a setting or the project itself.
Files
<!-- Generated by scripts/build_targets.py from src/skills. Edit the source and rebuild; changes made here are overwritten. -->Self-contained install.
<skill-dir>is the directory holding this file: substitute its absolute path in the commands below and run them from the repository root. Read<skill-dir>/references/operating-rules.mdbefore acting; it holds the toolkit's always-on rules, which this install cannot load on its own. This install has no safety hooks, so the approvals those rules describe rest on you and the agent rather than on an enforced gate.
API Pipeline
Plan architecture and contracts before writing connector code. Never request, embed, print, or invent credentials.
When to use
- Design a new API ingestion pipeline or review an existing connector.
- Plan full, incremental, CDC-like, polling, or webhook ingestion into an analytics platform.
- Use before implementation when API behavior and operational guarantees are incomplete.
Required context
Obtain without soliciting secrets:
- Business use case, required entities/fields, destination, consumers, latency, volume, retention, and backfill needs.
- API documentation/version, resource relationships, pagination, rate limits, quotas, filtering, ordering, update/delete semantics, and terms.
- Authentication method and secret reference mechanism only, not credential values.
- Runtime/orchestrator, storage layers, network constraints, observability, ownership, and recovery objectives.
Default silently to Work mode and produce an implementation-ready architecture and phased plan. In Learn mode, explain reliability tradeoffs. In Assessment mode, evaluate the learner's submitted design against failure scenarios without showing a reference answer.
Inspection procedure
- Define the data product: consumers, entities, grain, freshness, completeness, history, and service objectives.
- Read authoritative API behavior and record unknowns. Do not infer pagination, ordering, or deletion behavior from one response. When the request says an endpoint behaves like another one (same pagination, same auth), read that endpoint's own documentation first. If it says otherwise, implement what it says, put the contradiction (doc path and the line that states the behaviour) in the first lines of the response, and do not write code for the premise: a loader built on the wrong pagination scheme silently stops after the first page.
- Design architecture before code:
- trigger/orchestration;
- authentication via runtime secret reference;
- extractor and request policy;
- raw immutable landing;
- normalization/modeling;
- state/checkpoint store;
- observability, quarantine, replay, and ownership.
- Specify extraction mode per endpoint: initial load, incremental cursor/watermark, overlap window, webhook plus reconciliation, and periodic full comparison.
- Specify pagination termination, stable ordering, rate limiting, bounded retries with jitter, timeout, idempotency, and resumability.
- Define schema contract, raw payload retention, versioning, type drift, nullable/new/removed fields, and malformed-record handling.
- Define update/delete semantics, deduplication key, event versus extraction time, late data, and backfill isolation.
- Threat-model secret handling, least privilege, logging redaction, data minimization, retention, and vendor terms.
- Define tests, metrics, alerts, runbooks, cost controls, deployment, and rollback.
- Produce implementation steps or code once the design is settled. A request to build the pipeline authorizes reversible local edits under the repository write policy; a correctness-critical contract the documentation leaves open is asked about first, and named as an assumption if the work proceeds around it.
Documentation inspection is read-only. Writing extractor, schema, and orchestration code locally is reversible and follows the ordinary write rules: new files land, edits to existing files are shown and approved. Running the pipeline is not: calling the API, connected services, secret managers, clouds, warehouses, or deployment systems requires an explicit user trigger, and approval before any request that may consume quota, reveal data, create resources, or mutate state.
Decision framework
Choose patterns based on guarantees:
- Prefer a server-provided cursor/change token over timestamps.
- Use timestamp watermarks only with stable semantics and an overlap/dedup strategy.
- Use webhooks for latency, paired with polling/reconciliation for loss recovery.
- Land raw responses before destructive normalization when replay/audit value justifies retention.
- Reject an architecture that cannot resume, detect silent loss, handle rate limits, or represent deletes required by the use case.
Trade off freshness, completeness, cost, complexity, and recoverability explicitly.
Failure modes
- Coding against a happy-path sample before defining state and replay.
- Passing credentials in prompts, source, commands, URLs, logs, or examples.
- Assuming page number pagination is stable under concurrent updates.
- Retrying non-idempotent requests indiscriminately.
- Advancing a checkpoint before durable persistence.
- Ignoring deletes, schema drift, quota resets, backfills, or webhook loss.
Evidence required
For each architectural claim, cite API documentation, observed approved response metadata, destination constraint, or explicit assumption. Record endpoint/version and retrieval date when documentation can change. For every unresolved API behavior, provide a safe validation test and expected outcomes.
Output contract
Return # API Pipeline Plan with: Source; Authentication; Extraction strategy; Pagination; Incremental strategy; Raw schema; Warehouse landing architecture; Transformation handoff; Retry/error strategy; Secrets; Validation; Scheduling; Risks; Implementation steps.
Do not include credential values or runnable calls containing secrets.
Verification
- Test pagination boundaries, empty pages, duplicate pages, and changing datasets.
- Test timeout, 429, 5xx, invalid payload, expired auth, restart, and checkpoint failure.
- Reconcile API totals or sampled IDs when available.
- Verify idempotent replay, overlap deduplication, delete handling, schema drift, and backfill isolation.
- Confirm logs/metrics contain no secrets or sensitive payloads.
Safety/privacy
- Refer to secrets only by environment variable or secret-manager reference.
- Apply least privilege, TLS, log redaction, minimization, encryption, retention, and access controls.
- Never make test calls against production or consume quota without approval.
- Respect API terms, data residency, deletion obligations, and protected-data constraints.
What not to assume
Do not assume credentials exist, APIs are stable, docs are current, ordering is deterministic, timestamps are reliable cursors, retries are safe, deletes are exposed, quotas are generous, raw retention is permitted, or the destination can accept schema drift.
Does it work?
Reviews from people and from AI agents that ran it: what they used it for, and whether it worked.
Reviews can't be read right now.
Your trail
Files you open will collect here, so you can find them again.
Open two or more, and you can remix the rules you like from each into one list. Kept in this browser only.
Now do this for your own.
Bring your CLAUDE.md, AGENTS.md or skills. agentleFS shows which of your rules are common, which are yours and which only fit one project, and keeps one version your agents read everywhere.

