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
14DbtCloudRunJobOperatorAsync
from astronomer.providers.dbt.cloud.operators.dbt import DbtCloudRunJobOperatorAsync
15EmrContainerOperatorAsync
from astronomer.providers.amazon.aws.operators.emr import EmrContainerOperatorAsync
16GKEStartPodOperatorAsync
from astronomer.providers.google.cloud.operators.kubernetes_engine import GKEStartPodOperatorAsync
17KubernetesPodOperatorAsync
from astronomer.providers.cncf.kubernetes.operators.kubernetes_pod import KubernetesPodOperatorAsync
18LivyOperatorAsync
from astronomer.providers.apache.livy.operators.livy import LivyOperatorAsync
19RedshiftDataOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_data import RedshiftDataOperatorAsync
20RedshiftDeleteClusterOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftDeleteClusterOperatorAsync
21RedshiftPauseClusterOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftPauseClusterOperatorAsync
22RedshiftResumeClusterOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_cluster import RedshiftResumeClusterOperatorAsync
23RedshiftSQLOperatorAsync
from astronomer.providers.amazon.aws.operators.redshift_sql import RedshiftSQLOperatorAsync
24SageMakerProcessingOperatorAsync
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerProcessingOperatorAsync
25SageMakerTrainingOperatorAsync
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerTrainingOperatorAsync
26SageMakerTransformOperatorAsync
from astronomer.providers.amazon.aws.operators.sagemaker import SageMakerTransformOperatorAsync
27SnowflakeOperatorAsync
from astronomer.providers.snowflake.operators.snowflake import SnowflakeOperatorAsync
28SnowflakeSqlApiOperatorAsync
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
4DbtCloudJobRunSensorAsync
from astronomer.providers.dbt.cloud.sensors.dbt import DbtCloudJobRunSensorAsync
5EmrContainerSensorAsync
from astronomer.providers.amazon.aws.sensors.emr import EmrContainerSensorAsync
6EmrJobFlowSensorAsync
from astronomer.providers.amazon.aws.sensors.emr import EmrJobFlowSensorAsync
7EmrStepSensorAsync
from astronomer.providers.amazon.aws.sensors.emr import EmrStepSensorAsync
8ExternalDeploymentTaskSensorAsync
from astronomer.providers.core.sensors.external_task import ExternalDeploymentTaskSensorAsync
9ExternalTaskSensorAsync
from astronomer.providers.core.sensors.external_task import ExternalTaskSensorAsync
10FileSensorAsync
from astronomer.providers.core.sensors.filesystem import FileSensorAsync
11GCSObjectExistenceSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectExistenceSensorAsync
12GCSObjectUpdateSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectUpdateSensorAsync
13GCSObjectsWithPrefixExistenceSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSObjectsWithPrefixExistenceSensorAsync
14GCSUploadSessionCompleteSensorAsync
from astronomer.providers.google.cloud.sensors.gcs import GCSUploadSessionCompleteSensorAsync
15HivePartitionSensorAsync
from astronomer.providers.apache.hive.sensors.hive_partition import HivePartitionSensorAsync
16HttpSensorAsync
from astronomer.providers.http.sensors.http import HttpSensorAsync
17NamedHivePartitionSensorAsync
from astronomer.providers.apache.hive.sensors.named_hive_partition import NamedHivePartitionSensorAsync
18RedshiftClusterSensorAsync
from astronomer.providers.amazon.aws.sensors.redshift_cluster import RedshiftClusterSensorAsync
19S3KeySensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3KeySensorAsync
20S3KeySizeSensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3KeySizeSensorAsync
21S3KeysUnchangedSensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3KeysUnchangedSensorAsync
22S3PrefixSensorAsync
from astronomer.providers.amazon.aws.sensors.s3 import S3PrefixSensorAsync
23SFTPSensorAsync
from astronomer.providers.sftp.sensors.sftp import SFTPSensorAsync
24SnowflakeSensorAsync
from astronomer.providers.snowflake.sensors.snowflake import SnowflakeSensorAsync
25WasbBlobSensorAsync
from astronomer.providers.microsoft.azure.sensors.wasb import WasbBlobSensorAsync
26WasbPrefixSensorAsync
from astronomer.providers.microsoft.azure.sensors.wasb import WasbPrefixSensorAsync