Drt Create Sync Agent Skill

Generate a drt sync YAML configuration file.

Context cost
2.5k tokensestimated from the bundle, loaded when it triggers
Bundle
1 file · 10.0 kBtext throughout, nothing executable
Licence
Apache-2.0the author’s own terms
Last change
—no release on file
Servers it uses
Noneruns standalone

What it does

Generate a drt sync YAML configuration file. Use this skill whenever a user wants to create a new drt sync, connect a data warehouse table to an external service, or set up a Reverse ETL pipeline with drt.

What this skill changes about the agent has not been set out here as a list. Its SKILL.md, shown below, says it in the author’s own words.

database
Filed under

Databases

The skill itself

A skill is instructions the model reads, so you can see what you are getting: below is the start of its SKILL.md. The front matter loads with every session, the body loads when the skill triggers, and the whole file comes with the install.

SKILL.md10.0 kB · preview
--- name: drt-create-sync ---
9Create a drt sync YAML configuration file for the user.
10
11## Steps
12
131. Ask the user for the following (or infer from context if already provided):
14 - **Source table or SQL**: what data to sync (e.g. ref('new_users') or a SQL query)
15 - **Destination**: where to send it (Slack, Discord, Microsoft Teams, REST API, HubSpot, GitHub Actions, Google Sheets, PostgreSQL, MySQL, ClickHouse, Snowflake, Databricks Delta Lake, BigQuery, Parquet, CSV/JSON/JSONL, Amazon S3, Google Cloud Storage (GCS), Azure Blob Storage, Jira, Linear, SendGrid, Amplitude, Mixpanel, Klaviyo, Meta Conversions API, Notion, Twilio, Intercom, Zendesk, Google Ads, Email SMTP, Elasticsearch/OpenSearch, Staged Upload (async bulk APIs), Salesforce Bulk, Airtable, or other)
16 - **Sync mode**: full (every run), incremental (cursor/watermark-based), upsert (dedup by key), replace (full-table rebuild), or mirror (upsert + delete removed rows; requires upsert_key). Replace/mirror are supported on Postgres, MySQL, ClickHouse, Snowflake, Databricks, and BigQuery. Mirror strategy: destination (default) compares with the whole target; strategy: tracked deletes only rows drt previously synced and can combine with scope on all five non-BigQuery warehouse destinations; strategy: diff deletes exact removals from snapshot-diff incremental and works on all six, but rejects scope. BigQuery does not support tracked.
17 - **Incremental strategy**: use the default cursor strategy (mode: incremental + cursor_field) when the model has a reliable monotonic column. For a Postgres, Snowflake, Databricks, or BigQuery source without one, offer mode: upsert (or mirror) + incremental_strategy: diff + destination upsert_key; optionally set diff.hash_columns to a non-empty list instead of all. This materializes full snapshots in the source profile's managed_schema, needs warehouse create/write/drop privileges, and same-sync runs must not overlap. --limit never promotes the snapshot baseline.
18 - **Match policy (optional)**: sync.match_policy (v0.8.1, #757) narrows the upsert write path (mode: full / upsert / incremental) to one side — update_only touches only rows that already exist in the destination (no-match rows are **skipped, not created** — the CRM enrichment case: push warehouse-computed fields into records reps already made), create_only inserts only rows that don't yet exist (existing left untouched). Skips are counted in SyncResult.skipped / skipped_no_match (shown as … N skipped (M no match)), never errors. Rejected for mode: replace / mirror; fails fast on destinations that don't implement it. Supported on **Postgres** and **HubSpot** as of v0.8.1; other SaaS / SQL destinations follow
19 - **Frequency intent**: helps set batch_size and rate_limit
20 - **Column renames (optional)**: if source column names differ from destination field names, use sync.field_mappings: {source_column: destination_field} (#415) instead of aliasing in SQL — applied just before the destination, so cursor_field / lookups / computed_fields use source names while upsert_key / destination columns use the mapped names
21 - **Derived columns (optional)**: if the destination needs a shape the warehouse model shouldn't own (a concatenated full_name, E.164 phone, epoch-millis timestamp, an environment stamp), use sync.computed_fields: {field_name: "<jinja>"} (#763) rather than adding a destination-specific column to the dbt mart. Reads source column names as {{ row.col }}; same Jinja env / filters / StrictUndefined as body_template. Transform order is computed_fields → field_mappings → mask. A **single-expression** template keeps the Python value's type ({{ row.n * 1000 }} → 5000, not "5000"); anything with surrounding text renders as a string. A computed field can never read another one (order-independent). Writing an existing column name replaces it in place and reads the original value. ⚠️ A null passed *through a filter* renders as the string "None" — write {{ (row.phone or '') | replace('-','') }}. See docs/guides/computed-fields.md
22 - **PII masking (optional)**: to obscure a field before it reaches the destination without touching the source SQL, use sync.mask (v0.7.10, #427/#660). Flat form for parameter-less strategies — sync.mask: {email: hash, ssn: redact} (hash = SHA-256 hex, redact = [REDACTED]); object form for truncate — sync.mask: {name: {strategy: truncate, length: 2}} (keeps the first N chars). Runs at the same seam as field_mappings (after the rename), so mask keys reference the destination-facing field name; nulls pass through, works on every destination. See docs/guides/pii-masking.md
23 - **Bookkeeping columns (optional)**: to mark *when* a row synced, *which run* produced it, or *which sync* owns it, use sync.metadata_columns: {synced_at: _drt_synced_at, run_id: _drt_run_id, sync_name: _drt_sync_name} (#762) — any subset of the three. Plain dict enrichment at the engine seam (not DDL), so the target column must already exist on the destination. Runs **last** of every transform, after mask — the opposite end from computed_fields, since these are engine bookkeeping values, not derived from source data. See docs/guides/metadata-columns.md
24 - **Project vars (optional)**: values that differ between environments (a lookback window, a campaign tag) can live in a vars: block in drt_project.yml and be referenced as {{ var('name') }} / {{ var('name', default) }} in the model SQL and in YAML string fields (v0.8.0, #783). Override per run with drt run --vars 'lookback_days: 1' (precedence: --vars > DRT_VAR_<NAME> env > project vars:). An undefined var with no default is a drt validate error
25 - **Operational persistence (optional)**: Postgres, Snowflake, Databricks, and BigQuery profiles accept managed_schema: _drt. Project state: {backend: warehouse, connection_profile: <profile>} stores run state, history, and DLQ there. This is separate from sync.watermark.storage. Any *_env field may instead contain an aws-sm://, gcp-sm://, or vault:// secret-provider URI when the matching extra is installed.
26 - **Retry safety / quota identity (optional)**: REST APIs can send native_idempotency_key through native_idempotency_header; Google Ads maps it to orderId. Do not claim protection for destinations where drt validate says the field is unwired. For staged_upload, set public YAML field rate_limit_key to a stable, non-secret quota identity when regional hosts share a vendor quota or independent accounts share a host.
27 - **Sparse positional outputs**: Google Sheets fixes its columns from the first batch's first-seen key union. A field first appearing in a later batch fails with column mismatch; increase sync.batch_size so sparse fields appear in batch one. For historical Klaviyo events, use backfill: true (revision 2026-07-15 or newer) to avoid firing live flows, then turn it off for live incremental events.
This is a preview of SKILL.md. Download or install the skill to get the whole thing.
In the file
SKILL.md1,407 words
Files1
LicenceApache-2.0
Why you can read it

Nothing in a skill executes. The client loads the text and the model follows it, so a skill can be audited the way a runbook is — by reading it.

What it costs in context

Skills are not billed by the call. They are paid for in context: every token the instructions occupy is a token your code, your diff and your conversation cannot use. Here is what this one takes and when it takes it.

≈60
always loaded
The name and description, so the model knows the skill exists and when to reach for it.
2,440
on trigger
The instruction body, read only when the skill fires.
1.3%
of a 200k window
Ten skills this size would take about 13% of the window before you open a file.
050k100k150k200k context window

2.5k tokens, estimated from the bundle at four bytes to the token, held for the rest of the session once it triggers. Middling. Fine to keep on in a project where you use it weekly, worth unloading in one where you never do.

Servers bill, skills cost

A server charges by the month. A skill charges once per session, in context, and then keeps charging it for as long as the session lives.

Before and after

The same question, put to the same model twice: once as it comes, and once with these instructions loaded.

No worked example has been published for this skill yet.

The procedure it runs

The procedure has not been set out here step by step. It is in the body of its SKILL.md: the start of it is shown above, and the whole file comes with the install.

Prose, not code

These steps are written for a model to follow, not executed by a runtime. It can still be told to skip one, and it will say so when it does.

Servers it uses

None. This skill calls no MCP servers at all.

Everything it needs is in the instructions, so it works in a project with nothing connected — the model reads the file and changes how it works with what it can already reach.

Its SKILL.md does not declare which tools it asks the agent for, so what it touches is whatever the instructions themselves ask for — read them before you install it.

What it asks for
Writes filesnot declared
Network accessnot declared

This SKILL.md carries no allowed-tools line, so neither is declared. A skill grants no permissions of its own — it can only ask for tools your client already has.

What it will not do

Every skill is narrow, and the useful ones say where they stop. These are the jobs this one is the wrong tool for.

What this skill is not for has not been published here. Nothing is implied by that: it is a section the author has not filled in.

What is in the bundle

1 file, 10.0 kB on disk. A bundle is text throughout: the instructions the model reads, plus the templates it fills in.

  • SKILL.md10.0 kB
What is not in it

No dependencies and nothing executable: a skill is text the agent reads, so the bundle is 1 file you can review in full before installing. The Apache-2.0 licence covers the templates and examples as well as the instructions.

Install

Installing copies the bundle into your project. Nothing runs at install time — the files sit on disk until the model reads them.

# Drt Create Sync · 2.5k tokens when loaded · macOS, Linux mkdir -p .claude/skills && t=$(mktemp -d) && curl -fsSL -o "$t/bundle.tar.gz" https://mcprush.com/api/skills/drt-create-sync/bundle.tar.gz && tar -xzf "$t/bundle.tar.gz" -C "$t" && [ -d "$t/drt-create-sync" ] && { [ ! -e .claude/skills/drt-create-sync ] || { mv .claude/skills/drt-create-sync "$t/.previous" && echo "Previous copy moved to $t/.previous"; }; } && mv "$t/drt-create-sync" .claude/skills/ && echo "Installed .claude/skills/drt-create-sync"
On Windows, or any OS with Node 20+
npx mcprush@latest skill add drt-hub/drt-create-sync

Windows PowerShell says 'running scripts is disabled on this system'? Run Set-ExecutionPolicy -Scope CurrentUser RemoteSigned once, or type npx.cmd instead of npx (codex.cmd, gemini.cmd, grok.cmd likewise). PowerShell 7 needs neither. Writes to .claude/skills/drt-create-sync/ in the current project. For every project instead, run mkdir -p ~/.claude/skills && t=$(mktemp -d) && curl -fsSL -o "$t/bundle.tar.gz" https://mcprush.com/api/skills/drt-create-sync/bundle.tar.gz && tar -xzf "$t/bundle.tar.gz" -C "$t" && [ -d "$t/drt-create-sync" ] && { [ ! -e ~/.claude/skills/drt-create-sync ] || { mv ~/.claude/skills/drt-create-sync "$t/.previous" && echo "Previous copy moved to $t/.previous"; }; } && mv "$t/drt-create-sync" ~/.claude/skills/ && echo "Installed ~/.claude/skills/drt-create-sync" (macOS, Linux) — or add --global to the npx line. The curl line replaces .claude/skills/drt-create-sync/ only after the download succeeds, so files left there by another skill of the same name, or by an older release, do not mix in. A copy already there is moved aside, not deleted, and the line prints where.

Which clients pick it up on their own

A skill is a folder of text. Most of these read a skills folder and pick it up without being told; the rest take the same folder another way — an upload in the app, a parameter on an API call — and then choose it by its description just the same.

Claude Code.claude/skills/
Claude DesktopCustomize › Skills
ChatGPTSkills › Create › Upload
Cursor.cursor/skills/
VS Code.github/skills/
Codex CLI.agents/skills/
Gemini CLI.gemini/skills/
Grok Build.grok/skills/
Microsoft CopilotSkills › Upload a skill
PerplexityComputer › Skills › Upload a skill
DeepSeek Harness.dsh/skills/
Zed.agents/skills/
Devin Desktop.devin/skills/
Windsurf (legacy).windsurf/skills/
OpenAI Agents SDKInstructions or sandbox Skills
HTTP / APIa request parameter
This release
Versionnot versioned
Publishedno release date on file
PriceFree
Referencedrt-hub/drt-create-sync

Versions

Its author publishes no version number, so there is nothing here to pin to: what you install is the folder as it stands today. Instructions change more often than APIs do — a skill can be rewritten entirely without anything it depends on moving.

Pinning

Nothing to pin to: this skill carries no version number of its own. What you install is what the folder holds on the day you install it.

Reviews

—no reviews yet

Nobody has reviewed this skill yet. The rating is the mean of the reviews written here, so there is none until somebody writes the first.

Sign in to review it

A review is tied to an account so it can be answered, edited and taken down by the person who wrote it.

Sign in
Who can post

Anybody with an account, one review each. It carries the version that was current when you wrote it, and the publisher may reply once.

Publisher
Servers0
Claim this skill