Available Operators and Sensors

Since astronomer-providers>=1.19.0, most of the operators and sensors are now deprecated and their instantiations are proxied to their upstream Apache Airflow providers’ deferrable counterparts. Please check the deprecation status in the Deprecated column in the tables below. If the status is Yes, then you’re suggested to use the replacement suggestion provided as New Path in the Import path column and pass the deferrable=True param to the operator/sensor instantiation in your DAG.

Operators

#Operator nameDeprecatedImport path
1AzureDataFactoryRunPipelineOperatorAsync✅Old Path: 
from astronomer.providers.microsoft.azure.operators.data_factory import AzureDataFactoryRunPipelineOperatorAsync
 New Path: 
from airflow.providers.microsoft.azure.operators.data_factory import AzureDataFactoryRunPipelineOperator
2BatchOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.batch import BatchOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.batch import BatchOperator
3BigQueryCheckOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.bigquery import BigQueryCheckOperatorAsync
 New Path: 
from google.cloud.operators.bigquery import BigQueryCheckOperator
4BigQueryGetDataOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.bigquery import BigQueryGetDataOperatorAsync
 New Path: 
from google.cloud.operators.bigquery import BigQueryGetDataOperator
5BigQueryInsertJobOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.bigquery import BigQueryInsertJobOperatorAsync
 New Path: 
from google.cloud.operators.bigquery import BigQueryInsertJobOperator
6BigQueryIntervalCheckOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.bigquery import BigQueryIntervalCheckOperatorAsync
 New Path: 
from google.cloud.operators.bigquery import BigQueryIntervalCheckOperator
7BigQueryValueCheckOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.bigquery import BigQueryValueCheckOperatorAsync
 New Path: 
from google.cloud.operators.bigquery import BigQueryValueCheckOperator
8DatabricksRunNowOperatorAsync✅Old Path: 
from astronomer.providers.databricks.operators.databricks import DatabricksRunNowOperatorAsync
 New Path: 
from airflow.providers.databricks.operators.databricks import DatabricksRunNowOperator
9DatabricksSubmitRunOperatorAsync✅Old Path: 
from astronomer.providers.databricks.operators.databricks import DatabricksSubmitRunOperatorAsync
 New Path: 
from airflow.providers.databricks.operators.databricks import DatabricksSubmitRunOperator
10DataprocCreateClusterOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.dataproc import DataprocCreateClusterOperatorAsync
 New Path: 
from airflow.providers.google.cloud.operators.dataproc import DataprocCreateClusterOperator
11DataprocDeleteClusterOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.dataproc import DataprocDeleteClusterOperatorAsync
 New Path: 
from airflow.providers.google.cloud.operators.dataproc import DataprocDeleteClusterOperator
12DataprocSubmitJobOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.dataproc import DataprocSubmitJobOperatorAsync
 New Path: 
from airflow.providers.google.cloud.operators.dataproc import DataprocSubmitJobOperator
13DataprocUpdateClusterOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.dataproc import DataprocUpdateClusterOperatorAsync
 New Path: 
from airflow.providers.google.cloud.operators.dataproc import DataprocUpdateClusterOperator
14DbtCloudRunJobOperatorAsync✅Old Path: 
from astronomer.providers.dbt.cloud.operators.dbt import DbtCloudRunJobOperatorAsync
 New Path: 
from airflow.providers.dbt.cloud.operators.dbt import DbtCloudRunJobOperator
15EmrContainerOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.emr import EmrContainerOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.emr import EmrContainerOperator
16GKEStartPodOperatorAsync✅Old Path: 
from astronomer.providers.google.cloud.operators.kubernetes_engine import GKEStartPodOperatorAsync
 New Path: 
from airflow.providers.google.cloud.operators.kubernetes_engine import GKEStartPodOperator
17KubernetesPodOperatorAsync✅Old Path: 
from astronomer.providers.cncf.kubernetes.operators.kubernetes_pod import KubernetesPodOperatorAsync
 New Path: 
from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
18LivyOperatorAsync✅Old Path: 
from astronomer.providers.apache.livy.operators.livy import LivyOperatorAsync
 New Path: 
from airflow.providers.apache.livy.operators.livy import LivyOperator
19RedshiftDataOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.redshift_data import RedshiftDataOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.redshift_data import RedshiftDataOperator
20RedshiftDeleteClusterOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftDeleteClusterOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.redshift_cluster import RedshiftDeleteClusterOperator
21RedshiftPauseClusterOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftPauseClusterOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.redshift_cluster import RedshiftPauseClusterOperator
22RedshiftResumeClusterOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftResumeClusterOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.redshift_cluster import RedshiftResumeClusterOperator
23RedshiftSQLOperatorAsync❌
from astronomer.providers.amazon.aws.operators.redshift_sql import RedshiftSQLOperatorAsync
24SageMakerProcessingOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerProcessingOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerProcessingOperator
25SageMakerTrainingOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerTrainingOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerTrainingOperator
26SageMakerTransformOperatorAsync✅Old Path: 
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerTransformOperatorAsync
 New Path: 
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerTransformOperator
27SnowflakeOperatorAsync❌
from astronomer.providers.snowflake.operators.snowflake import SnowflakeOperatorAsync
28SnowflakeSqlApiOperatorAsync✅Old Path: 
from astronomer.providers.snowflake.operators.snowflake import SnowflakeSqlApiOperatorAsync
 New Path: 
from airflow.providers.snowflake.operators.snowflake import SnowflakeSqlApiOperator

Sensors

#Sensor nameDeprecatedImport path
1AzureDataFactoryPipelineRunStatusSensorAsync✅Old Path: 
from astronomer.providers.microsoft.azure.sensors.data_factory import AzureDataFactoryPipelineRunStatusSensorAsync
 New Path: 
from airflow.providers.microsoft.azure.sensors.data_factory import AzureDataFactoryPipelineRunStatusSensor
2BatchSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.batch import BatchSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.batch import BatchSensor
3BigQueryTableExistenceSensorAsync✅Old Path: 
from astronomer.providers.google.cloud.sensors.bigquery import BigQueryTableExistenceSensorAsync
 New Path: 
from airflow.providers.google.cloud.sensors.bigquery import BigQueryTableExistenceSensor
4DbtCloudJobRunSensorAsync✅Old Path: 
from astronomer.providers.dbt.cloud.sensors.dbt import DbtCloudJobRunSensorAsync
 New Path: 
from airflow.providers.dbt.cloud.sensors import DbtCloudJobRunSensor
5EmrContainerSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.emr import EmrContainerSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.emr import EmrContainerSensor
6EmrJobFlowSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.emr import EmrJobFlowSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.emr import EmrJobFlowSensor
7EmrStepSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.emr import EmrStepSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.emr import EmrStepSensor
8ExternalDeploymentTaskSensorAsync❌
from astronomer.providers.core.sensors.external_task import ExternalDeploymentTaskSensorAsync
9ExternalTaskSensorAsync✅Old Path: 
from astronomer.providers.core.sensors.external_task import ExternalTaskSensorAsync
 New Path: 
from airflow.sensors.external_task import ExternalTaskSensor
10FileSensorAsync✅Old Path: 
from astronomer.providers.core.sensors.filesystem import FileSensorAsync
 New Path: 
from airflow.sensors.filesystem import FileSensor
11GCSObjectExistenceSensorAsync✅Old Path: 
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectExistenceSensorAsync
 New Path: 
from airflow.providers.google.cloud.sensors.gcs import GCSObjectExistenceSensor
12GCSObjectUpdateSensorAsync✅Old Path: 
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectUpdateSensorAsync
 New Path: 
from airflow.providers.google.cloud.sensors.gcs import GCSObjectUpdateSensor
13GCSObjectsWithPrefixExistenceSensorAsync✅Old Path: 
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectsWithPrefixExistenceSensorAsync
 New Path: 
from airflow.providers.google.cloud.sensors.gcs import GCSObjectsWithPrefixExistenceSensor
14GCSUploadSessionCompleteSensorAsync✅Old Path: 
from astronomer.providers.google.cloud.sensors.gcs import GCSUploadSessionCompleteSensorAsync
 New Path: 
from airflow.providers.google.cloud.sensors.gcs import GCSUploadSessionCompleteSensor
15HivePartitionSensorAsync❌
from astronomer.providers.apache.hive.sensors.hive_partition import HivePartitionSensorAsync
16HttpSensorAsync✅Old Path: 
from astronomer.providers.http.sensors.http import HttpSensorAsync
 New Path: 
from airflow.providers.http.sensors.http import HttpSensor
17NamedHivePartitionSensorAsync❌
from astronomer.providers.apache.hive.sensors.named_hive_partition import NamedHivePartitionSensorAsync
18RedshiftClusterSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.redshift_cluster import RedshiftClusterSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.redshift_cluster import RedshiftClusterSensor
19S3KeySensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.s3 import S3KeySensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.s3 import S3KeySensor
20S3KeySizeSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.s3 import S3KeySizeSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.s3 import S3KeySensor
21S3KeysUnchangedSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.s3 import S3KeysUnchangedSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.s3 import S3KeysUnchangedSensor
22S3PrefixSensorAsync✅Old Path: 
from astronomer.providers.amazon.aws.sensors.s3 import S3PrefixSensorAsync
 New Path: 
from airflow.providers.amazon.aws.sensors.s3 import S3KeySensor
23SFTPSensorAsync✅Old Path: 
from astronomer.providers.sftp.sensors.sftp import SFTPSensorAsync
 New Path: 
from airflow.providers.sftp.sensors.sftp import SFTPSensor
24SnowflakeSensorAsync❌
from astronomer.providers.snowflake.sensors.snowflake import SnowflakeSensorAsync
25WasbBlobSensorAsync✅Old Path: 
from astronomer.providers.microsoft.azure.sensors.wasb import WasbBlobSensorAsync
 New Path: 
from airflow.providers.microsoft.azure.sensors.wasb import WasbBlobSensor
26WasbPrefixSensorAsync✅Old Path: 
from astronomer.providers.microsoft.azure.sensors.wasb import WasbPrefixSensorAsync
 New Path: 
from airflow.providers.microsoft.azure.sensors.wasb import WasbPrefixSensor