Skill Claude CodeCodex
Use this skill when the user wants to convert a Prefect @task function containing arbitrary Python logic (computation, API calls, pandas, boto3, etc.) into an equivalent Orchestra Python pipeline task. Triggers: any mention of migrating or rewriting Prefect @task functions to Orchestra; Prefect flow code with @task…
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that uses SlackAPIOperator, SlackWebhookOperator, or SlackAPIPostMessageOperator — or Airflow onfailurecallback / onsuccesscallback functions that send Slack messages — into an equivalent Orchestra pipeline alert or task. Also covers a plain PythonOperator…
Skill Claude CodeCodex
Use this skill when the user wants to convert Dagster Slack notifications — SlackResource, makeslackonrunfailuresensor, makeslackonfreshnesspolicystatuschangesensor, or op success/failure hooks that post to Slack — into an equivalent Orchestra pipeline alert or task. Triggers: any mention of migrating or rewriting…
Skill Claude CodeCodex
Use this skill when the user wants to convert Prefect Slack notifications into an equivalent Orchestra pipeline alert or task. This covers both hook-based notifications — SlackWebhook block, @flow onfailure/oncompletion hooks, Prefect Automation Slack notifications — AND explicit mid-flow Slack messages, including a…
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that uses TableauOperator or TableauRefreshWorkbookOperator (apache-airflow-providers-tableau) into an equivalent Orchestra pipeline task targeting Tableau Cloud. Triggers: any mention of migrating or rewriting Tableau Airflow tasks to Orchestra; Airflow…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Dagster Tableau integration — TableauCloudWorkspace, TableauServerWorkspace, loadtableauassetspecs, or buildtableaumaterializableassetsdefinition — into an equivalent Orchestra pipeline task targeting Tableau Cloud. Triggers: any mention of migrating or rewriting Dagster…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Prefect @task that refreshes a Tableau workbook or extract — using tableau-server-client (TSC) library, RefreshWorkbookRequest, or ScheduleItem — into an equivalent Orchestra pipeline task targeting Tableau Cloud. Triggers: any mention of migrating Tableau refresh…
Plugin Claude Code
Skills for working with Orchestra data pipelines — diagnose and fix failed runs, triage with a merge gate, author pipeline YAML, set up dbt Slim CI, configure dbt state-aware orchestration (source freshness and buildafter), run Snowflake data-quality tests, review a workspace against best practices, and merge duplicat.
Skill Claude CodeCodex
Audit an Orchestra workspace/account against Orchestra's best practices and produce a read-only health report — findings grouped by area, each tagged with severity, evidence, and a fix recommendation, written to a markdown file plus a chat summary. Use whenever the user wants an "account review", "workspace audit"…
Skill Claude CodeCodex
Builds Orchestra pipeline YAML using the native Data Reconciliation tasks (DATARECONCILIATIONMANUALQUERY, DATARECONCILIATIONCURSORFIELD) to prove two data stores match — the "did the migration land correctly" check between a source and destination integration (SNOWFLAKE, SQLSERVER, DATABRICKS, any pairing). Use…
Skill Claude CodeCodex
Configure dbt model buildafter for Orchestra state-aware orchestration — author the config.freshness.buildafter block (count, period, updateson) on dbt models so Orchestra rebuilds a model only after a minimum SLA window AND when its upstream data is fresh, then ensure usestateorchestration is enabled on the Orchestra…
Skill Claude CodeCodex
Configure dbt source freshness for Orchestra state-aware orchestration — author warnafter/errorafter thresholds and loadedatfield/loadedatquery in a dbt project's sources YAML, getting the warehouse details right for Snowflake, BigQuery, Databricks, or MotherDuck/DuckDB, then enable usestateorchestration on the…
MCP server Claude CodeCodexCursor
MCP server "orchestramcp" as configured in orchestra-hq/orchestra-mcp. Runs locally from the orchestramcp Python package.