Skill Claude CodeCodex
Use this skill when converting any Dagster job/schedule/Definitions to Orchestra YAML to handle top-level configuration. Triggers: any Dagster code containing ScheduleDefinition, @schedule, buildschedulefrompartitionedjob, RetryPolicy, op/run concurrency limits, run tags (dagster/maxruntime), Config classes, EnvVar…
Skill Claude CodeCodex
Use this skill when a Dagster project passes data between ops/assets via return values, Out/In wiring, IO managers, or context.addoutputmetadata, and you need that data flow represented in Orchestra. Triggers: any op/asset that returns a value consumed downstream, any custom or built-in IOManager, any use of…
Skill Claude CodeCodex
Use this skill when a Dagster project contains sensors that watch external state and trigger runs: @sensor, @assetsensor, @multiassetsensor, buildsensorforfreshnesschecks, or sensors polling S3/files/tables. Triggers: any @sensor that yields RunRequest based on external state (a file arriving, a row appearing), any…
Skill Claude CodeCodex
Use this skill when a Dagster project shells out or runs containers (non-dbt): PipesSubprocessClient / openpipessession, dagster-shell (executeshellcommand / createshellcommandop), SSHResource (dagster-ssh) running remote commands, k8sjobop / PipesK8sClient, PipesECSClient, or PipesDatabricksClient. Triggers: any op…
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that runs dbt Core commands — via BashOperator, SSHOperator, PythonOperator, KubernetesPodOperator, or Astronomer Cosmos — into an equivalent Orchestra pipeline task. Triggers: any mention of migrating or rewriting dbt Core Airflow tasks to Orchestra…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Dagster dbt integration — DbtCliResource, @dbtassets, dbtassets, builddbtassetselection, or DbtProject — into an equivalent Orchestra pipeline task. Triggers: any mention of migrating or rewriting Dagster dbt assets to Orchestra; Dagster code importing from dagsterdbt…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Prefect task that runs dbt Core commands — DbtCoreOperation block, ShellOperation running dbt CLI, rundbtbuild / rundbttest tasks, or DbtCloudJob — into an equivalent Orchestra pipeline task. Triggers: any mention of migrating or rewriting Prefect dbt tasks to Orchestra…
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that uses FivetranOperator or FivetranSensor (apache-airflow-providers-fivetran) into an equivalent Orchestra pipeline task. Triggers: any mention of migrating or rewriting Fivetran Airflow tasks to Orchestra; Airflow DAG code containing FivetranOperator or…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Dagster Fivetran integration — FivetranResource / FivetranWorkspace, buildfivetranassets, loadfivetranassetspecs, or fivetranassets — into an equivalent Orchestra pipeline task. Triggers: any mention of migrating or rewriting Dagster Fivetran assets/resources to…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Prefect task that syncs Fivetran — FivetranConnector block, triggersyncandwaitforcompletion, or FivetranSyncResult — into an equivalent Orchestra pipeline task. Triggers: any mention of migrating or rewriting Prefect Fivetran tasks to Orchestra; any Prefect flow code…
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that uses PowerBIDatasetRefreshOperator (apache-airflow-providers-microsoft-azure, module airflow.providers.microsoft.azure.operators.powerbi) into an equivalent Orchestra pipeline task targeting Power BI. Triggers: any mention of migrating or rewriting…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Dagster Power BI integration — PowerBIWorkspace, PowerBIServicePrincipal/PowerBIToken, loadpowerbiassetspecs, buildsemanticmodelrefreshassetdefinition, or a custom resource/op calling powerbi.triggerandpollrefresh — into an equivalent Orchestra pipeline task targeting…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Prefect @task that refreshes a Power BI dataset (semantic model) or dataflow — typically using msal/requests against the Power BI REST API, or a custom PowerBIBlock/ConfigurableResource wrapping it — into an equivalent Orchestra pipeline task targeting Power BI.…
Skill Claude CodeCodex
Use this skill when a Prefect project sends notifications: @flow(onfailure=...) or @flow(oncompletion=...) hooks, Prefect Automation notification actions (Slack, email, Teams, PagerDuty), SlackWebhook block notifications, or MicrosoftTeamsWebhook block notifications. Covers all six Orchestra alert destination types…
Skill Claude CodeCodex
Use this skill when a Prefect project uses Automations to trigger flow runs based on external events — storage events (S3/GCS file arrivals), database polling, scheduled automations, or webhook-triggered deployments. Triggers: any Prefect Automation watching external state, any flow.serve() with event-based triggers…
Skill Claude CodeCodex
Use this skill when a Prefect flow contains conditional execution logic: tasks that only run based on the result of upstream tasks, if/else branches driven by task return values, allowfailure=True patterns, or conditional .submit() calls. Triggers: any Prefect flow with if/else branching on task outputs, any task…
Skill Claude CodeCodex
Use this skill when converting Prefect code that references blocks holding credentials (SnowflakeCredentials, AwsCredentials, SlackWebhook, or any other loaded via Block.load()), Secret blocks, or environment-variable-based credentials to Orchestra. Triggers: any Prefect block that stores host/login/token/key, any…
Skill Claude CodeCodex
Use this skill when a Prefect flow triggers another deployment using rundeployment(), or when a flow is called as a subflow from a parent @flow. Triggers: any Prefect code with rundeployment(), await rundeployment(), or a @flow function called inside another @flow (subflow pattern).
Skill Claude CodeCodex
Use this skill when a Prefect flow passes data between tasks via return values (.result()), task.submit() futures, Prefect Artifacts, or .map() for fan-out. Triggers: any Prefect flow where a downstream task consumes the return value of an upstream task, any .map() usage, any Prefect Artifact that is read by a…
Skill Claude CodeCodex
Use this skill when converting any Prefect flow to Orchestra YAML to handle flow-level configuration. Triggers: any Prefect flow definition containing @flow, schedule= (CronSchedule, IntervalSchedule, RRuleSchedule), retries=, timeoutseconds=, flow.deploy() or flow.serve() deployment config, flow parameters (typed…
Skill Claude CodeCodex
Use this skill when the user has Prefect Secret blocks, SecretStr fields, SecretDict, or prefect.blocks.system.Secret usage to move into Orchestra. Triggers: any Prefect code using Secret.load(), .getsecretvalue(), SecretStr type annotations, or AWS Secrets Manager blocks storing credentials. Never asks for real…
Skill Claude CodeCodex
Use this skill when a Prefect flow contains data quality or testing logic: @task functions that run SQL assertions, Great Expectations checkpoints called from a @task, Soda check tasks, or threshold checks that raise exceptions on failure. Triggers: any Prefect @task that queries a database to validate data, any use…
Skill Claude CodeCodex
Use this skill when the user wants to convert an Airflow task that uses PythonOperator or PythonVirtualenvOperator into an equivalent Orchestra Python pipeline task. Triggers: any mention of migrating or rewriting PythonOperator tasks to Orchestra; Airflow DAG code using PythonOperator, PythonVirtualenvOperator…
Skill Claude CodeCodex
Use this skill when the user wants to convert a Dagster @op or @asset that runs arbitrary Python (computation, API calls, pandas, boto3) into an equivalent Orchestra Python pipeline task. Triggers: any mention of migrating or rewriting Dagster ops/assets to Orchestra; plain @op / @asset / @multiasset functions…