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 nameIs deprecated?Import path
1AzureDataFactoryRunPipelineOperatorAsync Yes 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 Yes Old Path:
from astronomer.providers.amazon.aws.operators.batch import BatchOperatorAsync
New Path:
from airflow.providers.amazon.aws.operators.batch import BatchOperator
3BigQueryCheckOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.bigquery import BigQueryCheckOperatorAsync
New Path:
from google.cloud.operators.bigquery import BigQueryCheckOperator
4BigQueryGetDataOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.bigquery import BigQueryGetDataOperatorAsync
New Path:
from google.cloud.operators.bigquery import BigQueryGetDataOperator
5BigQueryInsertJobOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.bigquery import BigQueryInsertJobOperatorAsync
New Path:
from google.cloud.operators.bigquery import BigQueryInsertJobOperator
6BigQueryIntervalCheckOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.bigquery import BigQueryIntervalCheckOperatorAsync
New Path:
from google.cloud.operators.bigquery import BigQueryIntervalCheckOperator
7BigQueryValueCheckOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.bigquery import BigQueryValueCheckOperatorAsync
New Path:
from google.cloud.operators.bigquery import BigQueryValueCheckOperator
8DatabricksRunNowOperatorAsync Yes Old Path:
from astronomer.providers.databricks.operators.databricks import DatabricksRunNowOperatorAsync
New Path:
from airflow.providers.databricks.operators.databricks import DatabricksRunNowOperator
9DatabricksSubmitRunOperatorAsync Yes Old Path:
from astronomer.providers.databricks.operators.databricks import DatabricksSubmitRunOperatorAsync
New Path:
from airflow.providers.databricks.operators.databricks import DatabricksSubmitRunOperator
10DataprocCreateClusterOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.dataproc import DataprocCreateClusterOperatorAsync
New Path:
from airflow.providers.google.cloud.operators.dataproc import DataprocCreateClusterOperator
11DataprocDeleteClusterOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.dataproc import DataprocDeleteClusterOperatorAsync
New Path:
from airflow.providers.google.cloud.operators.dataproc import DataprocDeleteClusterOperator
12DataprocSubmitJobOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.dataproc import DataprocSubmitJobOperatorAsync
New Path:
from airflow.providers.google.cloud.operators.dataproc import DataprocSubmitJobOperator
13DataprocUpdateClusterOperatorAsync Yes Old Path:
from astronomer.providers.google.cloud.operators.dataproc import DataprocUpdateClusterOperatorAsync
New Path:
from airflow.providers.google.cloud.operators.dataproc import DataprocUpdateClusterOperator
14DbtCloudRunJobOperatorAsync Yes Old Path:
from astronomer.providers.dbt.cloud.operators.dbt import DbtCloudRunJobOperatorAsync
New Path:
from airflow.providers.dbt.cloud.operators.dbt import DbtCloudRunJobOperator
15EmrContainerOperatorAsync Yes Old Path:
from astronomer.providers.amazon.aws.operators.emr import EmrContainerOperatorAsync
New Path:
from airflow.providers.amazon.aws.operators.emr import EmrContainerOperator
16GKEStartPodOperatorAsync Yes 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 Yes Old Path:
from astronomer.providers.cncf.kubernetes.operators.kubernetes_pod import KubernetesPodOperatorAsync
New Path:
from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
18LivyOperatorAsync Yes Old Path:
from astronomer.providers.apache.livy.operators.livy import LivyOperatorAsync
New Path:
from airflow.providers.apache.livy.operators.livy import LivyOperator
19RedshiftDataOperatorAsync Yes 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 Yes 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 Yes 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 Yes 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 No
from astronomer.providers.amazon.aws.operators.redshift_sql import RedshiftSQLOperatorAsync
24SageMakerProcessingOperatorAsync Yes Old Path:
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerProcessingOperatorAsync
New Path:
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerProcessingOperator
25SageMakerTrainingOperatorAsync Yes Old Path:
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerTrainingOperatorAsync
New Path:
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerTrainingOperator
26SageMakerTransformOperatorAsync Yes Old Path:
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerTransformOperatorAsync
New Path:
from airflow.providers.amazon.aws.operators.sagemaker import SageMakerTransformOperator
27SnowflakeOperatorAsync No
from astronomer.providers.snowflake.operators.snowflake import SnowflakeOperatorAsync
28SnowflakeSqlApiOperatorAsync Yes Old Path:
from astronomer.providers.snowflake.operators.snowflake import SnowflakeSqlApiOperatorAsync
New Path:
from airflow.providers.snowflake.operators.snowflake import SnowflakeSqlApiOperator

Sensors

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