What is airbyte-cloud-dagster-to-orchestra?

A conversion guide for replacing Dagster tasks that start Airbyte Cloud syncs with Orchestra tasks. Dagster is a data-pipeline framework, while Airbyte Cloud copies data between connected systems.

Use it when migrating Dagster code that uses Airbyte Cloud resources or asset-building functions into an Orchestra pipeline.

It maps Dagster resources, assets, dependencies, and sync settings to Orchestra fields. It also explains that Orchestra waits for the sync itself, so a separate Dagster sensor is not needed.

airbyte-cloud-dagster-to-orchestra — Skill for Claude Code by orchestr

Install

Getting it into your agent

One page per mod, every tool's command on it. A separate URL per tool would split the same page into five that compete with each other.

Any agent

npx skills add orchestra-hq/orchestra-skills --skill airbyte-cloud-dagster-to-orchestra

Clone the repo

git clone --depth 1 https://github.com/orchestra-hq/orchestra-skills

Made for: Claude Code.

Or install migrate-to-orchestra, the plugin that ships this one along with the rest of its 52 skills.

Wrote this? Show the measurements

A badge with what this costs and how it scanned, read live from this page, so it follows the numbers instead of freezing them. Markdown for a README, HTML for a documentation site or a project page.

README.md

[![agentmods](https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airbyte-cloud-dagster-to-orchestra/github.svg)](https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airbyte-cloud-dagster-to-orchestra)

Your own site

<a href="https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airbyte-cloud-dagster-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airbyte-cloud-dagster-to-orchestra/github.svg" alt="Measured on agentmods" height="20"></a>

Or the 80×15 button, for a site that already has a row of RSS and ATOM ones. Only the verdict fits; the numbers stay here.

Your own site · 80×15

<a href="https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airbyte-cloud-dagster-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airbyte-cloud-dagster-to-orchestra.svg" alt="Reviewed on agentmods" width="80" height="20"></a>

Per session 97 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.

When invoked 1,364 The whole file, excluding the scripts and references it only reads on demand.

Security scan A 0 findings. A grade says what 26 rules found in the file — not that it is safe.

Origin original No closer match found in the catalogue.

Token cost

What it costs to keep this loaded

Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.

Model	Per session	Once invoked
Fable 5.1	$0.00097	$0.01364
Opus 5	$0.00048	$0.00682
Sonnet 5	$0.00019	$0.00273
Haiku 4.5	$0.00010	$0.00136

Measured 12d ago against content hash d063c290997b, method: parsed. Prices are Anthropic first-party input rates as of 2026-09-12, from the pricing page.

Security

Grade A, and why

airbyte-cloud-dagster-to-orchestra scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 12d ago.

A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.

Nothing flagged

None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.

skills/migrate-to-orchestra/skills/airbyte-cloud-dagster-to-orchestra/SKILL.md · 133 lines

How it starts

The opening of the file, as written. The whole thing — 133 lines — stays where its author put it; the contents beside it link to each section on GitHub.

Airbyte Cloud: Dagster -> Orchestra Conversion

Overview

In Dagster, Airbyte Cloud is integrated via dagster-airbyte: an AirbyteCloudResource holds credentials and build_airbyte_assets (or load_airbyte_cloud_asset_specs) turns each Airbyte connection into Dagster assets. Materializing those assets triggers the sync. In Orchestra the equivalent is a single Sync task under the AIRBYTE_CLOUD integration. Orchestra always polls for completion; there is no separate sensor.

Parameter Mapping

Dagster concept	Orchestra YAML field	Notes
`AirbyteCloudResource(api_key=...)`	`connection:`	Orchestra connection of type Airbyte Cloud (stores the API key)
`build_airbyte_assets(connection_id=...)`	`parameters.connection_id`	Airbyte Cloud connection UUID — copy verbatim
asset materialization	`parameters.job_type: sync`	Use `reset` for a full reload
`destination_tables=[...]`	(not needed)	Orchestra syncs the whole connection
asset key / name	`name:`	Human-readable task name
upstream asset deps	`depends_on:`	Upstream Orchestra task UUIDs/names

Orchestra YAML Structure

version: v1
name: <pipeline-name>
pipeline:
  <stage-uuid>:
    tasks:
      <task-uuid>:
        integration: AIRBYTE_CLOUD
        integration_job: AIRBYTE_CLOUD_JOB
        name: <descriptive name>
        connection: <orchestra-airbyte-cloud-connection-name>
        parameters:
          connection_id: <airbyte-connection-uuid>
          job_type: sync          # required: "sync" or "reset"
        depends_on: []
        condition: null
        tags: []

Conversion Steps

Find the Airbyte resource — locate AirbyteCloudResource and the connection_id passed to build_airbyte_assets / asset specs.
Find/create the Orchestra connection — in Orchestra Settings -> Connections, confirm an Airbyte Cloud connection exists. Its name goes in connection:.
Replace the asset(s) with a task block — one Orchestra task per Airbyte connection_id, copying the UUID verbatim.
Set job_type — sync normally, reset if the Dagster code performs a reset.
Wire dependencies — convert upstream asset dependencies to depends_on:.

Read the full file on GitHub · 133 lines

Changes

What this file has done since we first saw it

Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.

12d ago First seen · 133 lines · 97 tokens per session scan A d063c290997b

Subscribe to this mod's changes

airbyte-cloud-dagster-to-orchestra is a skill published in the GitHub repository orchestra-hq/orchestra-skills (9 stars, last pushed 3d ago), licensed MIT. It adds 97 tokens to every session and 1,364 once invoked, about $0.0005 per session on Opus 5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-08-31.

Backend and APIs Cloud DevOps and cloud

stripe-projects

Provision SaaS services + sync creds via Stripe Projects.

NousResearch/hermes-agent · 15 tokens

azure-eventhub-dotnet

Azure Event Hubs SDK for .NET. Use for high-throughput event streaming: sending events (EventHubProducerClient, EventHubBufferedProducerClient), receiving events (EventProcessorClient with checkpointing), partition management, and real-time data ingestion. Triggers: "Event Hubs", "event streaming"…

microsoft/skills · 94 tokens

azure-mgmt-botservice-dotnet

Azure Resource Manager SDK for Bot Service in .NET. Management plane operations for creating and managing Azure Bot resources, channels (Teams, DirectLine, Slack), and connection settings. Triggers: "Bot Service", "BotResource", "Azure Bot", "DirectLine channel", "Teams channel", "bot management .NET", "create bot".

microsoft/skills · 78 tokens

wikipedia

Search and read Wikipedia via x wkp — MediaWiki API, no API key, zero install; query, extract, suggest, and DDG route in one module. Load for wiki, wikipedia, encyclopedia lookup, article summary.

x-cmd/x-cmd · 49 tokens

cve

Look up CVE records via x cve — cached, zero-API-key, daily xz TSV. Load for cve, vulnerability id, kev, epss, nvd, cvelist, or security advisory.