Plugin Claude Code
Agent skills for diagnosing, fixing, triaging, and authoring Orchestra data pipelines, plus dbt Slim CI setup, Snowflake quality tests, and best-practice account reviews.
9 22d ago A
tokens not measured
original MIT
Instructions file CodexOpenCode
Instructions for orchestra-hq/orchestra-skills, covering agent guide — orchestra-skills, choose a skill first, migrating from another orchestrator, reference index and operating rules.
9 22d ago A 2,748 tokens
original MIT
Plugin Claude Code
Skills for converting Dagster, Prefect, and Airflow pipelines into Orchestra pipeline YAML — schedules and retries, dbt/Python/Airbyte/Fivetran/Tableau/Power BI/Slack tasks, connections and secrets, alerts, sensors/automations, branching/conditions, cross-job/cross-flow/cross-DAG dependencies, asset checks/testing…
9 22d ago A
tokens not measured
original MIT
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that uses AirbyteTriggerSyncOperator or AirbyteSensor (apache-airflow-providers-airbyte) into an equivalent Orchestra pipeline task targeting Airbyte Cloud. Triggers: any mention of migrating, converting, or rewriting Airflow Airbyte tasks to Orchestra; any…
9 22d ago A 94 tokens
original MIT
Skill Claude CodeCodex
Use this skill when the user wants to convert a Dagster integration that syncs Airbyte Cloud — AirbyteCloudResource, buildairbyteassets, loadairbytecloudassetspecs, or airbyteassets — into an equivalent Orchestra pipeline task targeting Airbyte Cloud. Triggers: any mention of migrating or rewriting Dagster Airbyte…
9 22d ago A 97 tokens
original MIT
Skill Claude CodeCodex
Use this skill when the user wants to convert a Prefect task that syncs Airbyte Cloud — AirbyteConnection block, triggersyncrunandwaitforcompletion, or AirbyteSyncResult — into an equivalent Orchestra pipeline task targeting Airbyte Cloud. Triggers: any mention of migrating or rewriting Prefect Airbyte tasks to…
9 22d ago A 92 tokens
original MIT
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that uses AirbyteTriggerSyncOperator or AirbyteSensor pointed at a self-hosted Airbyte Server instance into an equivalent Orchestra pipeline task. Triggers: any mention of migrating or converting Airflow self-hosted Airbyte tasks to Orchestra; Airflow DAG…
9 22d ago A 97 tokens
original MIT
Skill Claude CodeCodex
Use this skill when the user wants to convert a Dagster integration that syncs a self-hosted Airbyte Server (open-source / OSS) instance — AirbyteResource (with host/port) plus buildairbyteassets — into an equivalent Orchestra pipeline task. Triggers: any mention of migrating self-hosted Airbyte Dagster assets to…
9 22d ago A 110 tokens
original MIT
Skill Claude CodeCodex
Use this skill when the user wants to convert a Prefect task that syncs a self-hosted Airbyte Server — AirbyteConnection block, triggersyncrunandwaitforcompletion, or AirbyteSyncResult pointed at a non-Cloud host — into an equivalent Orchestra pipeline task targeting Airbyte Server. Triggers: any mention of migrating…
9 22d ago A 107 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG uses onfailurecallback, onsuccesscallback, onretrycallback, slamisscallback, EmailOperator, PagerDutyEventsHook, or any notification/alerting pattern. Covers all six Orchestra alert destination types: SLACK, EMAIL, PAGERDUTY, MICROSOFTTEAMS, WEBHOOK, and DATADOG. Read this skill…
9 22d ago A 98 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG contains BashOperator (non-dbt), SSHOperator (non-dbt), WinRMOperator, or KubernetesPodOperator. Triggers: any task using bashcommand= that isn't running dbt, any task using sshconnid= that isn't running dbt, any KubernetesPodOperator or DockerOperator. Note: BashOperator or…
9 22d ago A 124 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG contains conditional execution logic: triggerrule (alldone, onefailed, nonefailed, onesuccess, noneskipped), BranchPythonOperator, ShortCircuitOperator, or LatestOnlyOperator. Triggers: any Airflow task with a non-default triggerrule; any DAG using branching or short-circuit…
9 22d ago A 92 tokens
original MIT
Skill Claude CodeCodex
Use this skill when converting Airflow code that references credentials via Airflow's connection system: any operator/hook kwarg ending in connid (connid=, awsconnid=, snowflakeconnid=, sshconnid=, slackconnid=, gcpconnid=, httpconnid=), any BaseHook.getconnection(...) or Connection class usage, any AIRFLOWCONN…
9 22d ago A 164 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG uses TriggerDagRunOperator, ExternalTaskSensor, or SubDagOperator to create cross-DAG dependencies or trigger downstream pipelines. Triggers: any DAG with externaldagid=, triggerdagid=, SubDagOperator, or Airflow Datasets.
9 22d ago A 70 tokens
original MIT
Skill Claude CodeCodex
Use this skill when converting any Airflow DAG to Orchestra YAML to handle DAG-level configuration. Triggers: any Airflow DAG definition containing scheduleinterval, defaultargs, maxactiveruns, catchup, params, startdate, or DAG-level tags. Must be applied before converting individual tasks — it establishes the…
9 22d ago A 80 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG uses dynamic task mapping — task.expand(param=[...]), task.expand(param=XComArg(...)), task.partial(...).expand(...), or expandkwargs() (Airflow 2.3+) — to create a variable number of task instances at runtime from a list, dict, or an upstream task's output. Triggers: any DAG using…
9 22d ago A 148 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG contains sensor operators: S3KeySensor, FileSensor, SqlSensor, ExternalTaskSensor, TimeSensor, or any Sensor class. Triggers: any DAG with pokeinterval, mode='reschedule', or sensor-based waiting patterns. Sensors in Orchestra are first-class pipeline triggers defined in a sensors…
9 22d ago A 83 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG contains data quality or testing operators: SqlCheckOperator, SQLThresholdCheckOperator, GreatExpectationsOperator, SodaCheckOperator, DbtTestOperator, or any custom SQL assertion task. Triggers: any task with sql= parameter used for validation, any use of Great Expectations or Soda…
9 22d ago A 79 tokens
original MIT
Skill Claude CodeCodex
Use this skill when an Airflow DAG uses xcompush, xcompull, or the TaskFlow API @task return values to pass data between tasks. Triggers: any DAG with ti.xcompush(), context['ti'].xcompull(), @task decorated functions that return values, or BranchPythonOperator decisions driven by upstream XCom values.
9 22d ago A 80 tokens
original MIT
Skill Claude CodeCodex
Use this skill when a Dagster project sends notifications: @runfailuresensor, @runstatussensor, makeemailonrunfailuresensor, makeslackonrunfailuresensor, PagerDuty/Teams/Datadog resources used in hooks or sensors, or @failurehook/@successhook. Covers all six Orchestra alert destination types: SLACK, EMAIL, PAGERDUTY…
9 22d ago A 114 tokens
original MIT
Skill Claude CodeCodex
Use this skill when a Dagster project contains data quality / testing logic: @assetcheck, asset checks with AssetCheckResult, buildmetadataboundschecks, dbt tests run via dagster-dbt, dagster-pandera / dagstermill expectations, or ExpectationResult. Triggers: any @assetcheck decorated function, any AssetCheckSpec, any…
9 22d ago A 109 tokens
original MIT
Skill Claude CodeCodex
Use this skill when a Dagster job/graph contains conditional execution logic: ops with multiple Out/branching outputs that are conditionally yielded, @op functions that decide which downstream op runs, DynamicOut fan-out used for branching, or conditional asset materialization (AutomationCondition / skip logic).…
9 22d ago A 107 tokens
original MIT
Skill Claude CodeCodex
Use this skill when converting Dagster code that references resources holding credentials (ConfigurableResource subclasses, EnvVar, integration resources like SnowflakeResource / S3Resource / DbtCliResource, or resources wired into Definitions) to Orchestra. Triggers: any Dagster resource that stores…
9 22d ago A 98 tokens
original MIT
Skill Claude CodeCodex
Use this skill when a Dagster project creates dependencies between jobs/code locations or triggers downstream runs: @runstatussensor (on SUCCESS) yielding RunRequest, @assetsensor watching another job's asset, cross-code-location asset dependencies (SourceAsset / AssetKey across locations), or a sensor that launches…
9 22d ago A 101 tokens
original MIT