Airflow Operator Coverage Matrix

This document lists all Airflow operators supported by airflow-unfactor and their Prefect equivalents.

Quick Reference

StatusMeaning
SupportedFull conversion with Prefect integration
ScaffoldGenerates working scaffold code
ManualRequires manual review after conversion

Total Operators Supported: 35

AWS S3

Airflow OperatorPrefect FunctionIntegrationStatus
S3CreateObjectOperators3_uploadprefect-awsSupported
S3DeleteObjectsOperators3_deleteprefect-awsSupported
S3CopyObjectOperators3_copyprefect-awsSupported
S3ListOperators3_listprefect-awsSupported
S3FileTransformOperators3_transformprefect-awsSupported

AWS Compute

Airflow OperatorPrefect FunctionIntegrationStatus
LambdaInvokeFunctionOperatorlambda_invokeprefect-awsSupported
EcsRunTaskOperatorecs_run_taskprefect-awsSupported
EksCreateClusterOperatoreks_create_clusterprefect-awsSupported
EksPodOperatorkubernetes_jobprefect-kubernetesSupported

AWS Data

Airflow OperatorPrefect FunctionIntegrationStatus
GlueJobOperatorglue_jobprefect-awsSupported
GlueCrawlerOperatorglue_crawlerprefect-awsSupported
RedshiftSQLOperatorredshift_queryprefect-awsSupported

GCP Storage & BigQuery

Airflow OperatorPrefect FunctionIntegrationStatus
BigQueryInsertJobOperatorbigquery_queryprefect-gcpSupported
BigQueryExecuteQueryOperatorbigquery_queryprefect-gcpSupported
GCSCreateBucketOperatorcreate_gcs_bucketprefect-gcpSupported
GCSToGCSOperatorgcs_copyprefect-gcpSupported
GCSDeleteObjectsOperatorgcs_deleteprefect-gcpSupported
GCSFileTransformOperatorgcs_transformprefect-gcpSupported

GCP Compute

Airflow OperatorPrefect FunctionIntegrationStatus
DataprocSubmitJobOperatordataproc_jobprefect-gcpSupported
DataprocCreateClusterOperatordataproc_create_clusterprefect-gcpSupported

GCP Messaging

Airflow OperatorPrefect FunctionIntegrationStatus
PubSubPublishMessageOperatorpubsub_publishprefect-gcpSupported
PubSubCreateSubscriptionOperatorpubsub_create_subscriptionprefect-gcpSupported

Azure

Airflow OperatorPrefect FunctionIntegrationStatus
WasbBlobOperatorazure_blobprefect-azureSupported
AzureDataFactoryRunPipelineOperatoradf_run_pipelineprefect-azureSupported

Databricks

Airflow OperatorPrefect FunctionIntegrationStatus
DatabricksRunNowOperatordatabricks_run_nowprefect-databricksSupported
DatabricksSubmitRunOperatordatabricks_submit_runprefect-databricksSupported
DatabricksSqlOperatordatabricks_sqlprefect-databricksSupported

dbt

Airflow OperatorPrefect FunctionIntegrationStatus
DbtCloudRunJobOperatordbt_cloud_run_jobprefect-dbtSupported
DbtRunOperatordbt_runprefect-dbtSupported

Database

Airflow OperatorPrefect FunctionIntegrationStatus
PostgresOperatorexecute_sqlprefect-sqlalchemySupported
MySqlOperatorexecute_sqlprefect-sqlalchemySupported
SnowflakeOperatorsnowflake_queryprefect-snowflakeSupported

Notifications

Airflow OperatorPrefect FunctionIntegrationStatus
SlackAPIPostOperatorsend_messageprefect-slackSupported
EmailOperatoremail_send_messageprefect-emailSupported

Core Operators

Core Airflow operators are converted to native Prefect patterns:

Airflow OperatorPrefect PatternNotes
PythonOperator@task decoratorDirect function conversion
BashOperatorshell_run_commandShell task execution
BranchPythonOperatorConditional logicNative Python if/else
ShortCircuitOperatorEarly returnNative Python control flow
DummyOperatorRemovedNot needed in Prefect
EmptyOperatorRemovedNot needed in Prefect

Adding New Operators

To request support for an operator not listed:

  1. Check if a Prefect integration exists at prefect-integrations
  2. If an integration exists, open an issue with the operator details
  3. If no integration exists, the operator may require manual conversion

Using lookup_concept

For any operator in this matrix, lookup_concept provides the translation rules:

{
  "tool": "lookup_concept",
  "args": { "concept": "S3CreateObjectOperator" }
}

Returns the Prefect equivalent, required integration package, and conversion guidance. The LLM uses this to generate the correct Prefect code.