What is airbyte-server-prefect-to-orchestra?

A conversion guide for moving Prefect tasks that sync a self-hosted Airbyte Server into Orchestra. Airbyte is a data-integration service that copies data between sources and destinations; self-hosted means the server runs on your own infrastructure.

Use it when converting Prefect Airbyte tasks that connect to any Airbyte host other than Airbyte Cloud and start a sync or reset job.

It prevents a private Airbyte deployment from being treated as Airbyte Cloud. It maps the server connection, connection ID, and sync or full-reset operation to Orchestra fields.

airbyte-server-prefect-to-orchestra — Skill for Claude Code by orchest

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-server-prefect-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-server-prefect-to-orchestra/github.svg)](https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airbyte-server-prefect-to-orchestra)

Your own site

<a href="https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airbyte-server-prefect-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airbyte-server-prefect-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-server-prefect-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airbyte-server-prefect-to-orchestra.svg" alt="Reviewed on agentmods" width="80" height="20"></a>

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

When invoked 1,027 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.00107	$0.01027
Opus 5	$0.00053	$0.00513
Sonnet 5	$0.00021	$0.00205
Haiku 4.5	$0.00011	$0.00103

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

Security

Grade A, and why

airbyte-server-prefect-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-server-prefect-to-orchestra/SKILL.md · 102 lines

How it starts

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

Overview

This skill converts Prefect prefect_airbyte tasks targeting a self-hosted Airbyte Server (any host other than api.airbyte.com) into Orchestra pipeline tasks using integration: AIRBYTE_SERVER and integration_job: AIRBYTE_SERVER_JOB. It covers sync and reset job types.

Parameter Mapping

Prefect construct	Orchestra field	Notes
`AirbyteConnection.load("...")`	`connection:`	Orchestra Airbyte Server connection slug
`connection_id` (UUID)	`parameters.connection_id`	Copy verbatim — UUID string
`trigger_sync_run_and_wait_for_completion()`	`parameters.job_type: sync`	Orchestra always waits; no separate polling needed
`reset_cache=True`	`parameters.job_type: reset`	Full reload of the connection
Prefect block host (self-hosted)	`integration: AIRBYTE_SERVER`	Confirm host matches Orchestra connection's stored host

Orchestra YAML Structure

integration: AIRBYTE_SERVER
integration_job: AIRBYTE_SERVER_JOB
name: sync-task
connection: airbyte_server_prod_12345
parameters:
  connection_id: 'a1b2c3d4-e5f6-7890-abcd-ef1234567890'
  job_type: sync
depends_on: []
condition: null
tags: []

Conversion Steps

Confirm the Prefect block's airbyte_server_host is NOT api.airbyte.com — if it is, use airbyte-cloud-prefect-to-orchestra
Set integration: AIRBYTE_SERVER
Set integration_job: AIRBYTE_SERVER_JOB
Copy the connection_id UUID verbatim into parameters.connection_id
Map reset_cache=True → parameters.job_type: reset; otherwise parameters.job_type: sync
Set connection: to the Orchestra Airbyte Server connection slug — confirm its stored host URL matches the Prefect block's airbyte_server_host
Set depends_on: from upstream task dependencies

Before / After Example

Prefect (before)

from prefect import flow, task
from prefect_airbyte.connections import AirbyteConnection
from prefect_airbyte.flows import trigger_sync_run_and_wait_for_completion

@flow
def sync_airbyte_server():
    airbyte_conn = AirbyteConnection.load("my-airbyte-server-block")
    # block points to https://airbyte.internal.example.com
    trigger_sync_run_and_wait_for_completion(
        airbyte_connection=airbyte_conn,
        connection_id="a1b2c3d4-e5f6-7890-abcd-ef1234567890",
    )

Read the full file on GitHub · 102 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 · 102 lines · 107 tokens per session scan A b3f4de251b4b

Subscribe to this mod's changes

airbyte-server-prefect-to-orchestra is a skill published in the GitHub repository orchestra-hq/orchestra-skills (9 stars, last pushed 3d ago), licensed MIT. It adds 107 tokens to every session and 1,027 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.

systematic-debugging

Use when encountering any bug, test failure, or unexpected behavior, before proposing fixes.

obra/superpowers · 21 tokens

local-ai-agents

Build local-first AI agents that run entirely on a developer workstation with Microsoft Foundry Local and Qwen function-calling models. Covers Small Language Models (SLMs), the OpenAI-compatible local endpoint, sandboxed local tools, local RAG with Chroma, local MCP servers, hybrid cloud/local routing, and the…

microsoft/ai-agents-for-beginners · 200 tokens

next-cache-components-adoption

Turn on Cache Components in a Next.js app and resolve the blocking routes it surfaces. Use when the user wants to enable, adopt, or migrate to Cache Components, flip the cacheComponents flag, work through a flood of blocking-prerender / instant validation errors, run the cache-components-instant-false codemod, or…

vercel/next.js · 95 tokens

chat-pet-sprite-creation

Use when creating or changing VS Code chat pet sprite art, sprite sheets, state animations, eye treatments, Stable/Insiders variants, or pet transitions under src/vs/workbench/contrib/chat/browser/widget/media/chatPet.

microsoft/vscode · 53 tokens

cpu-profile-analysis

Analyze V8/Chrome CPU profiles (.cpuprofile) and DevTools trace files (Trace-.json). Use when: profiling performance, investigating slow functions, comparing code paths, finding bottlenecks, analyzing timeToRequest, understanding call trees from sampling profiler data, analyzing layout/paint/rendering, investigating…

microsoft/vscode · 71 tokens

insight-error-page

Write or audit an insight-kind error page for the Next.js dev overlay. Use when creating a new errors/ .mdx page, auditing an existing one, or checking that a page matches the framework fix cards. Covers page structure, title alignment, FixCard cards with Copy prompt button, code snippets, terminology verification…

vercel/next.js · 83 tokens