Available Operators and Sensors

Operators

#Operator nameImport path
1AzureDataFactoryRunPipelineOperatorAsync
from astronomer.providers.microsoft.azure.operators.data_factory import AzureDataFactoryRunPipelineOperatorAsync
2BatchOperatorAsync
from astronomer.providers.amazon.aws.operators.batch import BatchOperatorAsync
3BigQueryCheckOperatorAsync
from astronomer.providers.google.cloud.operators.bigquery import BigQueryCheckOperatorAsync
4BigQueryGetDataOperatorAsync
from astronomer.providers.google.cloud.operators.bigquery import BigQueryGetDataOperatorAsync
5BigQueryInsertJobOperatorAsync
from astronomer.providers.google.cloud.operators.bigquery import BigQueryInsertJobOperatorAsync
6BigQueryIntervalCheckOperatorAsync
from astronomer.providers.google.cloud.operators.bigquery import BigQueryIntervalCheckOperatorAsync
7BigQueryValueCheckOperatorAsync
from astronomer.providers.google.cloud.operators.bigquery import BigQueryValueCheckOperatorAsync
8DatabricksRunNowOperatorAsync
from astronomer.providers.databricks.operators.databricks import DatabricksRunNowOperatorAsync
9DatabricksSubmitRunOperatorAsync
from astronomer.providers.databricks.operators.databricks import DatabricksSubmitRunOperatorAsync
10DataprocCreateClusterOperatorAsync
from astronomer.providers.google.cloud.operators.dataproc import DataprocCreateClusterOperatorAsync
11DataprocDeleteClusterOperatorAsync
from astronomer.providers.google.cloud.operators.dataproc import DataprocDeleteClusterOperatorAsync
12DataprocSubmitJobOperatorAsync
from astronomer.providers.google.cloud.operators.dataproc import DataprocSubmitJobOperatorAsync
13DataprocUpdateClusterOperatorAsync
from astronomer.providers.google.cloud.operators.dataproc import DataprocUpdateClusterOperatorAsync
14EmrContainerOperatorAsync
from astronomer.providers.amazon.aws.operators.emr import EmrContainerOperatorAsync
15GKEStartPodOperatorAsync
from astronomer.providers.google.cloud.operators.kubernetes_engine import GKEStartPodOperatorAsync
16KubernetesPodOperatorAsync
from astronomer.providers.cncf.kubernetes.operators.kubernetes_pod import KubernetesPodOperatorAsync
17LivyOperatorAsync
from astronomer.providers.apache.livy.operators.livy import LivyOperatorAsync
18RedshiftDataOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_data import RedshiftDataOperatorAsync
19RedshiftDeleteClusterOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftDeleteClusterOperatorAsync
20RedshiftPauseClusterOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftPauseClusterOperatorAsync
21RedshiftResumeClusterOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftResumeClusterOperatorAsync
22RedshiftSQLOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_sql import RedshiftSQLOperatorAsync
23SnowflakeOperatorAsync
from astronomer.providers.snowflake.operators.snowflake import SnowflakeOperatorAsync
24SnowflakeSqlApiOperatorAsync
from astronomer.providers.snowflake.operators.snowflake import SnowflakeSqlApiOperatorAsync

Sensors

#Sensor nameImport path
1AzureDataFactoryPipelineRunStatusSensorAsync
from astronomer.providers.microsoft.azure.sensors.data_factory import AzureDataFactoryPipelineRunStatusSensorAsync
2BatchSensorAsync
from astronomer.providers.amazon.aws.sensors.batch import BatchSensorAsync
3BigQueryTableExistenceSensorAsync
from astronomer.providers.google.cloud.sensors.bigquery import BigQueryTableExistenceSensorAsync
4EmrContainerSensorAsync
from astronomer.providers.amazon.aws.sensors.emr import EmrContainerSensorAsync
5EmrJobFlowSensorAsync
from astronomer.providers.amazon.aws.sensors.emr import EmrJobFlowSensorAsync
6EmrStepSensorAsync
from astronomer.providers.amazon.aws.sensors.emr import EmrStepSensorAsync
7ExternalTaskSensorAsync
from astronomer.providers.core.sensors.external_task import ExternalTaskSensorAsync
8FileSensorAsync
from astronomer.providers.core.sensors.filesystem import FileSensorAsync
9GCSObjectExistenceSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectExistenceSensorAsync
10GCSObjectUpdateSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectUpdateSensorAsync
11GCSObjectsWithPrefixExistenceSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectsWithPrefixExistenceSensorAsync
12GCSUploadSessionCompleteSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSUploadSessionCompleteSensorAsync
13HivePartitionSensorAsync
from astronomer.providers.apache.hive.sensors.hive_partition import HivePartitionSensorAsync
14HttpSensorAsync
from astronomer.providers.http.sensors.http import HttpSensorAsync
15NamedHivePartitionSensorAsync
from astronomer.providers.apache.hive.sensors.named_hive_partition import NamedHivePartitionSensorAsync
16RedshiftClusterSensorAsync
from astronomer.providers.amazon.aws.sensors.redshift_cluster import RedshiftClusterSensorAsync
17S3KeySensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3KeySensorAsync
18S3KeySizeSensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3KeySizeSensorAsync
19S3KeysUnchangedSensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3KeysUnchangedSensorAsync
20S3PrefixSensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3PrefixSensorAsync
21WasbBlobSensorAsync
from astronomer.providers.microsoft.azure.sensors.wasb import WasbBlobSensorAsync
22WasbPrefixSensorAsync
from astronomer.providers.microsoft.azure.sensors.wasb import WasbPrefixSensorAsync