Google

apache-airflow-providers-google

Google services including Google Ads, Google Cloud (GCP), Google Firebase, Google LevelDB, Google Marketing Platform, Google Workspace (formerly Google Suite)

Works with Airflow 2.11+
52K
Monthly Downloads
901
Total Modules
View Docs Source
Install:
pip install apache-airflow-providers-google==22.7.0

Airflow

2.11+

Python

>=3.11

Dependencies (20)

Show all Hide apache-airflow>=2.11.0 apache-airflow-providers-common-compat>=1.13.0 apache-airflow-providers-common-sql>=1.32.0 asgiref>=3.5.2; python_version < '3.14' asgiref>=3.11.1; python_version >= '3.14' dill>=0.2.3 gcloud-aio-auth>=5.2.0 gcloud-aio-bigquery>=6.1.2 gcloud-aio-storage>=9.0.0 gcsfs>=2023.10.0 google-ads>=26.0.0,!=28.0.0.post2 google-analytics-admin>=0.9.0 google-api-core>=2.30.3 google-api-python-client>=2.193.0 google-auth>=2.29.0 google-auth-httplib2>=0.0.1 google-genai>=2.8.0 google-cloud-aiplatform[evaluation]>=1.164.0 ray[default]>=2.42.0;python_version<'3.13' ray[default]>=2.49.0;python_version>='3.13' and python_version <'3.14'

Connections (10)

URI Schemes (5)

Schemes this release registers in provider.yaml, grouped by the Airflow feature that routes them to the provider.

ObjectStoragePath
gcs:// gs://
Asset URIs
bigquery:// gcp:// gs://
Remote logging
gs:// stackdriver://

Modules

O

GoogleCloudBaseOperator

Abstract base class for operators using Google API client libraries.

airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator
View Docs Source
O

AlloyDBBaseOperator

Base class for all AlloyDB operators.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBBaseOperator
View Docs Source
O

AlloyDBCreateBackupOperator

Create a Backup in an Alloy DB cluster.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBCreateBackupOperator
View Docs Source
O

AlloyDBCreateClusterOperator

Create an Alloy DB cluster.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBCreateClusterOperator
View Docs Source
O

AlloyDBCreateInstanceOperator

Create an Instance in an Alloy DB cluster.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBCreateInstanceOperator
View Docs Source
O

AlloyDBCreateUserOperator

Create a User in an Alloy DB cluster.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBCreateUserOperator
View Docs Source
O

AlloyDBDeleteBackupOperator

Delete an Alloy DB backup.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBDeleteBackupOperator
View Docs Source
O

AlloyDBDeleteClusterOperator

Delete an Alloy DB cluster.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBDeleteClusterOperator
View Docs Source
O

AlloyDBDeleteInstanceOperator

Delete an Alloy DB instance.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBDeleteInstanceOperator
View Docs Source
O

AlloyDBDeleteUserOperator

Delete an Alloy DB user.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBDeleteUserOperator
View Docs Source
O

AlloyDBUpdateBackupOperator

Update an Alloy DB backup.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBUpdateBackupOperator
View Docs Source
O

AlloyDBUpdateClusterOperator

Update an Alloy DB cluster.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBUpdateClusterOperator
View Docs Source
O

AlloyDBUpdateInstanceOperator

Update an Alloy DB instance.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBUpdateInstanceOperator
View Docs Source
O

AlloyDBUpdateUserOperator

Update an Alloy DB user.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBUpdateUserOperator
View Docs Source
O

AlloyDBWriteBaseOperator

Base class for writing AlloyDB operators.

airflow.providers.google.cloud.operators.alloy_db.AlloyDBWriteBaseOperator
View Docs Source
O

BigQueryCheckOperator Deferrable

Performs checks against BigQuery.

airflow.providers.google.cloud.operators.bigquery.BigQueryCheckOperator
View Docs Source
O

BigQueryColumnCheckOperator

Subclasses the SQLColumnCheckOperator in order to provide a job id for OpenLineage to parse.

airflow.providers.google.cloud.operators.bigquery.BigQueryColumnCheckOperator
View Docs Source
O

BigQueryCreateEmptyDatasetOperator

Create a new dataset for your Project in BigQuery.

airflow.providers.google.cloud.operators.bigquery.BigQueryCreateEmptyDatasetOperator
View Docs Source
O

BigQueryCreateRoutineOperator

Create a BigQuery routine (UDF, stored procedure, table-valued function, or aggregate).

airflow.providers.google.cloud.operators.bigquery.BigQueryCreateRoutineOperator
View Docs Source
O

BigQueryCreateTableOperator

Creates a new table in the specified BigQuery dataset, optionally with schema.

airflow.providers.google.cloud.operators.bigquery.BigQueryCreateTableOperator
View Docs Source
O

BigQueryDeleteDatasetOperator

Delete an existing dataset from your Project in BigQuery.

airflow.providers.google.cloud.operators.bigquery.BigQueryDeleteDatasetOperator
View Docs Source
O

BigQueryDeleteRoutineOperator

Delete a BigQuery routine.

airflow.providers.google.cloud.operators.bigquery.BigQueryDeleteRoutineOperator
View Docs Source
O

BigQueryDeleteTableOperator

Delete a BigQuery table.

airflow.providers.google.cloud.operators.bigquery.BigQueryDeleteTableOperator
View Docs Source
O

BigQueryGetDataOperator Deferrable

Fetch data and return it, either from a BigQuery table, or results of a query job.

airflow.providers.google.cloud.operators.bigquery.BigQueryGetDataOperator
View Docs Source
O

BigQueryGetDatasetOperator

Get the dataset specified by ID.

airflow.providers.google.cloud.operators.bigquery.BigQueryGetDatasetOperator
View Docs Source
O

BigQueryGetDatasetTablesOperator

Retrieve the list of tables in the specified dataset.

airflow.providers.google.cloud.operators.bigquery.BigQueryGetDatasetTablesOperator
View Docs Source
O

BigQueryGetRoutineOperator

Fetch an existing BigQuery routine and return its serialized API representation via XCom.

airflow.providers.google.cloud.operators.bigquery.BigQueryGetRoutineOperator
View Docs Source
O

BigQueryInsertJobOperator Durable Deferrable

Execute a BigQuery job.

airflow.providers.google.cloud.operators.bigquery.BigQueryInsertJobOperator
View Docs Source
O

BigQueryIntervalCheckOperator Deferrable

Check that the values of metrics given as SQL expressions are within a tolerance of the older ones.

airflow.providers.google.cloud.operators.bigquery.BigQueryIntervalCheckOperator
View Docs Source
O

BigQueryListRoutinesOperator

List routines in a BigQuery dataset and return them as a list via XCom.

airflow.providers.google.cloud.operators.bigquery.BigQueryListRoutinesOperator
View Docs Source
O

BigQueryTableCheckOperator

Subclasses the SQLTableCheckOperator in order to provide a job id for OpenLineage to parse.

airflow.providers.google.cloud.operators.bigquery.BigQueryTableCheckOperator
View Docs Source
O

BigQueryUpdateDatasetOperator

Update a dataset for your Project in BigQuery.

airflow.providers.google.cloud.operators.bigquery.BigQueryUpdateDatasetOperator
View Docs Source
O

BigQueryUpdateRoutineOperator

Patch selected fields of an existing BigQuery routine.

airflow.providers.google.cloud.operators.bigquery.BigQueryUpdateRoutineOperator
View Docs Source
O

BigQueryUpdateTableOperator

Update a table for your Project in BigQuery.

airflow.providers.google.cloud.operators.bigquery.BigQueryUpdateTableOperator
View Docs Source
O

BigQueryUpdateTableSchemaOperator

Update BigQuery Table Schema.

airflow.providers.google.cloud.operators.bigquery.BigQueryUpdateTableSchemaOperator
View Docs Source
O

BigQueryUpsertTableOperator

Upsert to a BigQuery table.

airflow.providers.google.cloud.operators.bigquery.BigQueryUpsertTableOperator
View Docs Source
O

BigQueryValueCheckOperator Deferrable

Perform a simple value check using sql code.

airflow.providers.google.cloud.operators.bigquery.BigQueryValueCheckOperator
View Docs Source
O

BigQueryCreateDataTransferOperator

Creates a new data transfer configuration.

airflow.providers.google.cloud.operators.bigquery_dts.BigQueryCreateDataTransferOperator
View Docs Source
O

BigQueryDataTransferServiceStartTransferRunsOperator Deferrable

Start manual transfer runs to be executed now with schedule_time equal to current time.

airflow.providers.google.cloud.operators.bigquery_dts.BigQueryDataTransferServiceStartTransferRunsOperator
View Docs Source
O

BigQueryDeleteDataTransferConfigOperator

Deletes transfer configuration.

airflow.providers.google.cloud.operators.bigquery_dts.BigQueryDeleteDataTransferConfigOperator
View Docs Source
O

BigtableCreateInstanceOperator

Creates a new Cloud Bigtable instance.

airflow.providers.google.cloud.operators.bigtable.BigtableCreateInstanceOperator
View Docs Source
O

BigtableCreateTableOperator

Creates the table in the Cloud Bigtable instance.

airflow.providers.google.cloud.operators.bigtable.BigtableCreateTableOperator
View Docs Source
O

BigtableDeleteInstanceOperator

Deletes the Cloud Bigtable instance, including its clusters and all related tables.

airflow.providers.google.cloud.operators.bigtable.BigtableDeleteInstanceOperator
View Docs Source
O

BigtableDeleteTableOperator

Deletes the Cloud Bigtable table.

airflow.providers.google.cloud.operators.bigtable.BigtableDeleteTableOperator
View Docs Source
O

BigtableUpdateClusterOperator

Updates a Cloud Bigtable cluster.

airflow.providers.google.cloud.operators.bigtable.BigtableUpdateClusterOperator
View Docs Source
O

BigtableUpdateInstanceOperator

Updates an existing Cloud Bigtable instance.

airflow.providers.google.cloud.operators.bigtable.BigtableUpdateInstanceOperator
View Docs Source
O

CloudBuildCancelBuildOperator

Cancels a build in progress.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildCancelBuildOperator
View Docs Source
O

CloudBuildCreateBuildOperator Deferrable

Starts a build with the specified configuration.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildCreateBuildOperator
View Docs Source
O

CloudBuildCreateBuildTriggerOperator

Creates a new BuildTrigger.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildCreateBuildTriggerOperator
View Docs Source
O

CloudBuildDeleteBuildTriggerOperator

Deletes a BuildTrigger by its project ID and trigger ID.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildDeleteBuildTriggerOperator
View Docs Source
O

CloudBuildGetBuildOperator

Returns information about a previously requested build.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildGetBuildOperator
View Docs Source
O

CloudBuildGetBuildTriggerOperator

Returns information about a BuildTrigger.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildGetBuildTriggerOperator
View Docs Source
O

CloudBuildListBuildTriggersOperator

Lists existing BuildTriggers.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildListBuildTriggersOperator
View Docs Source
O

CloudBuildListBuildsOperator

Lists previously requested builds.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildListBuildsOperator
View Docs Source
O

CloudBuildRetryBuildOperator

Creates a new build using the original build request, which may or may not result in an identical build.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildRetryBuildOperator
View Docs Source
O

CloudBuildRunBuildTriggerOperator

Runs a BuildTrigger at a particular source revision.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildRunBuildTriggerOperator
View Docs Source
O

CloudBuildUpdateBuildTriggerOperator

Updates a BuildTrigger by its project ID and trigger ID.

airflow.providers.google.cloud.operators.cloud_build.CloudBuildUpdateBuildTriggerOperator
View Docs Source
O

CloudComposerCreateEnvironmentOperator Deferrable

Create a new environment.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerCreateEnvironmentOperator
View Docs Source
O

CloudComposerDeleteEnvironmentOperator Deferrable

Delete an environment.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerDeleteEnvironmentOperator
View Docs Source
O

CloudComposerGetEnvironmentOperator

Get an existing environment.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerGetEnvironmentOperator
View Docs Source
O

CloudComposerListEnvironmentsOperator

List environments.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerListEnvironmentsOperator
View Docs Source
O

CloudComposerListImageVersionsOperator

List ImageVersions for provided location.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerListImageVersionsOperator
View Docs Source
O

CloudComposerRunAirflowCLICommandOperator Deferrable

Run Airflow command for provided Composer environment.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerRunAirflowCLICommandOperator
View Docs Source
O

CloudComposerTriggerDAGRunOperator

Trigger Dag run for provided Composer environment.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerTriggerDAGRunOperator
View Docs Source
O

CloudComposerUpdateEnvironmentOperator Deferrable

Update an environment.

airflow.providers.google.cloud.operators.cloud_composer.CloudComposerUpdateEnvironmentOperator
View Docs Source
O

CloudRunCreateJobOperator

Creates a job without executing it. Pushes the created job to xcom.

airflow.providers.google.cloud.operators.cloud_run.CloudRunCreateJobOperator
View Docs Source
O

CloudRunCreateServiceOperator

Creates a Service without executing it. Pushes the created service to xcom.

airflow.providers.google.cloud.operators.cloud_run.CloudRunCreateServiceOperator
View Docs Source
O

CloudRunDeleteJobOperator

Deletes a job and wait for the operation to be completed. Pushes the deleted job to xcom.

airflow.providers.google.cloud.operators.cloud_run.CloudRunDeleteJobOperator
View Docs Source
O

CloudRunDeleteServiceOperator

Deletes a Service without executing it. Pushes the deleted service to xcom.

airflow.providers.google.cloud.operators.cloud_run.CloudRunDeleteServiceOperator
View Docs Source
O

CloudRunExecuteJobOperator Deferrable

Executes a job and waits for the operation to be completed. Pushes the executed job to xcom.

airflow.providers.google.cloud.operators.cloud_run.CloudRunExecuteJobOperator
View Docs Source
O

CloudRunListJobsOperator

Lists jobs.

airflow.providers.google.cloud.operators.cloud_run.CloudRunListJobsOperator
View Docs Source
O

CloudRunUpdateJobOperator

Updates a job and wait for the operation to be completed. Pushes the updated job to xcom.

airflow.providers.google.cloud.operators.cloud_run.CloudRunUpdateJobOperator
View Docs Source
O

CloudMemorystoreCreateInstanceAndImportOperator

Create a Redis instance and import a Redis RDB snapshot file from Cloud Storage into this instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreCreateInstanceAndImportOperator
View Docs Source
O

CloudMemorystoreCreateInstanceOperator

Creates a Redis instance based on the specified tier and memory size.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreCreateInstanceOperator
View Docs Source
O

CloudMemorystoreDeleteInstanceOperator

Deletes a specific Redis instance. Instance stops serving and data is deleted.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreDeleteInstanceOperator
View Docs Source
O

CloudMemorystoreExportAndDeleteInstanceOperator

Export Redis instance data into a Redis RDB format file in Cloud Storage.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreExportAndDeleteInstanceOperator
View Docs Source
O

CloudMemorystoreExportInstanceOperator

Export Redis instance data into a Redis RDB format file in Cloud Storage.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreExportInstanceOperator
View Docs Source
O

CloudMemorystoreFailoverInstanceOperator

Initiate a failover of the primary node for a specific STANDARD tier Cloud Memorystore for Redis instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreFailoverInstanceOperator
View Docs Source
O

CloudMemorystoreGetInstanceOperator

Gets the details of a specific Redis instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreGetInstanceOperator
View Docs Source
O

CloudMemorystoreImportOperator

Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreImportOperator
View Docs Source
O

CloudMemorystoreListInstancesOperator

Lists all Redis instances owned by a project in either the specified location (region) or all locations.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreListInstancesOperator
View Docs Source
O

CloudMemorystoreMemcachedApplyParametersOperator

Will update current set of Parameters to the set of specified nodes of the Memcached Instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreMemcachedApplyParametersOperator
View Docs Source
O

CloudMemorystoreMemcachedCreateInstanceOperator

Creates a Memcached instance based on the specified tier and memory size.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreMemcachedCreateInstanceOperator
View Docs Source
O

CloudMemorystoreMemcachedDeleteInstanceOperator

Deletes a specific Memcached instance. Instance stops serving and data is deleted.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreMemcachedDeleteInstanceOperator
View Docs Source
O

CloudMemorystoreMemcachedGetInstanceOperator

Gets the details of a specific Memcached instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreMemcachedGetInstanceOperator
View Docs Source
O

CloudMemorystoreMemcachedListInstancesOperator

List all Memcached instances owned by a project in either the specified location/region or all locations.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreMemcachedListInstancesOperator
View Docs Source
O

CloudMemorystoreMemcachedUpdateInstanceOperator

Updates the metadata and configuration of a specific Memcached instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreMemcachedUpdateInstanceOperator
View Docs Source
O

CloudMemorystoreMemcachedUpdateParametersOperator

Updates the defined Memcached Parameters for an existing Instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreMemcachedUpdateParametersOperator
View Docs Source
O

CloudMemorystoreScaleInstanceOperator

Updates the metadata and configuration of a specific Redis instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreScaleInstanceOperator
View Docs Source
O

CloudMemorystoreUpdateInstanceOperator

Updates the metadata and configuration of a specific Redis instance.

airflow.providers.google.cloud.operators.cloud_memorystore.CloudMemorystoreUpdateInstanceOperator
View Docs Source
O

CloudSQLBaseOperator

Abstract base operator for Google Cloud SQL operators.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLBaseOperator
View Docs Source
O

CloudSQLCloneInstanceOperator

Clone an instance to a target instance.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLCloneInstanceOperator
View Docs Source
O

CloudSQLCreateInstanceDatabaseOperator

Create a new database inside a Cloud SQL instance.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLCreateInstanceDatabaseOperator
View Docs Source
O

CloudSQLCreateInstanceOperator

Create a new Cloud SQL instance.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLCreateInstanceOperator
View Docs Source
O

CloudSQLDeleteInstanceDatabaseOperator

Delete a database from a Cloud SQL instance.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLDeleteInstanceDatabaseOperator
View Docs Source
O

CloudSQLDeleteInstanceOperator

Delete a Cloud SQL instance.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLDeleteInstanceOperator
View Docs Source
O

CloudSQLExecuteQueryOperator

Perform DML or DDL query on an existing Cloud Sql instance.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLExecuteQueryOperator
View Docs Source
O

CloudSQLExportInstanceOperator Deferrable

Export data from a Cloud SQL instance to a Cloud Storage bucket.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLExportInstanceOperator
View Docs Source
O

CloudSQLImportInstanceOperator

Import data into a Cloud SQL instance from Cloud Storage.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLImportInstanceOperator
View Docs Source
O

CloudSQLInstancePatchOperator

Update settings of a Cloud SQL instance.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLInstancePatchOperator
View Docs Source
O

CloudSQLPatchInstanceDatabaseOperator

Update resource containing information about a database using patch semantics.

airflow.providers.google.cloud.operators.cloud_sql.CloudSQLPatchInstanceDatabaseOperator
View Docs Source
O

CloudDataTransferServiceCancelOperationOperator

Cancels a transfer operation in Google Storage Transfer Service.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceCancelOperationOperator
View Docs Source
O

CloudDataTransferServiceCreateJobOperator

Creates a transfer job that runs periodically.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceCreateJobOperator
View Docs Source
O

CloudDataTransferServiceDeleteJobOperator

Delete a transfer job.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceDeleteJobOperator
View Docs Source
O

CloudDataTransferServiceGCSToGCSOperator Deferrable

Copies objects from a bucket to another using the Google Cloud Storage Transfer Service.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceGCSToGCSOperator
View Docs Source
O

CloudDataTransferServiceGetOperationOperator

Gets the latest state of a long-running operation in Google Storage Transfer Service.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceGetOperationOperator
View Docs Source
O

CloudDataTransferServiceListOperationsOperator

Lists long-running operations in Google Storage Transfer Service that match the specified filter.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceListOperationsOperator
View Docs Source
O

CloudDataTransferServicePauseOperationOperator

Pauses a transfer operation in Google Storage Transfer Service.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServicePauseOperationOperator
View Docs Source
O

CloudDataTransferServiceResumeOperationOperator

Resumes a transfer operation in Google Storage Transfer Service.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceResumeOperationOperator
View Docs Source
O

CloudDataTransferServiceRunJobOperator Deferrable

Runs a transfer job.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceRunJobOperator
View Docs Source
O

CloudDataTransferServiceS3ToGCSOperator Deferrable

Sync an S3 bucket with a Google Cloud Storage bucket using the Google Cloud Storage Transfer Service.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceS3ToGCSOperator
View Docs Source
O

CloudDataTransferServiceUpdateJobOperator

Updates a transfer job that runs periodically.

airflow.providers.google.cloud.operators.cloud_storage_transfer_service.CloudDataTransferServiceUpdateJobOperator
View Docs Source
O

ComputeEngineBaseOperator

Abstract base operator for Google Compute Engine operators to inherit from.

airflow.providers.google.cloud.operators.compute.ComputeEngineBaseOperator
View Docs Source
O

ComputeEngineCopyInstanceTemplateOperator

Copies the instance template, applying specified changes.

airflow.providers.google.cloud.operators.compute.ComputeEngineCopyInstanceTemplateOperator
View Docs Source
O

ComputeEngineDeleteInstanceGroupManagerOperator

Permanently and irrevocably deletes an Instance Group Managers.

airflow.providers.google.cloud.operators.compute.ComputeEngineDeleteInstanceGroupManagerOperator
View Docs Source
O

ComputeEngineDeleteInstanceOperator

Deletes an Instance in Google Compute Engine.

airflow.providers.google.cloud.operators.compute.ComputeEngineDeleteInstanceOperator
View Docs Source
O

ComputeEngineDeleteInstanceTemplateOperator

Deletes an Instance Template in Google Compute Engine.

airflow.providers.google.cloud.operators.compute.ComputeEngineDeleteInstanceTemplateOperator
View Docs Source
O

ComputeEngineInsertInstanceFromTemplateOperator

Creates an Instance in Google Compute Engine based on specified parameters from existing Template.

airflow.providers.google.cloud.operators.compute.ComputeEngineInsertInstanceFromTemplateOperator
View Docs Source
O

ComputeEngineInsertInstanceGroupManagerOperator

Creates an Instance Group Managers using the body specified.

airflow.providers.google.cloud.operators.compute.ComputeEngineInsertInstanceGroupManagerOperator
View Docs Source
O

ComputeEngineInsertInstanceOperator

Creates an Instance in Google Compute Engine based on specified parameters.

airflow.providers.google.cloud.operators.compute.ComputeEngineInsertInstanceOperator
View Docs Source
O

ComputeEngineInsertInstanceTemplateOperator

Creates an Instance Template using specified fields.

airflow.providers.google.cloud.operators.compute.ComputeEngineInsertInstanceTemplateOperator
View Docs Source
O

ComputeEngineInstanceGroupUpdateManagerTemplateOperator

Patches the Instance Group Manager, replacing source template URL with the destination one.

airflow.providers.google.cloud.operators.compute.ComputeEngineInstanceGroupUpdateManagerTemplateOperator
View Docs Source
O

ComputeEngineSetMachineTypeOperator

Changes the machine type for a stopped instance to the machine type specified in the request.

airflow.providers.google.cloud.operators.compute.ComputeEngineSetMachineTypeOperator
View Docs Source
O

ComputeEngineStartInstanceOperator

Starts an instance in Google Compute Engine.

airflow.providers.google.cloud.operators.compute.ComputeEngineStartInstanceOperator
View Docs Source
O

ComputeEngineStopInstanceOperator

Stops an instance in Google Compute Engine.

airflow.providers.google.cloud.operators.compute.ComputeEngineStopInstanceOperator
View Docs Source
O

DataflowCreatePipelineOperator

Creates a new Dataflow Data Pipeline instance.

airflow.providers.google.cloud.operators.dataflow.DataflowCreatePipelineOperator
View Docs Source
O

DataflowDeletePipelineOperator

Deletes a Dataflow Data Pipeline.

airflow.providers.google.cloud.operators.dataflow.DataflowDeletePipelineOperator
View Docs Source
O

DataflowRunPipelineOperator

Runs a Dataflow Data Pipeline.

airflow.providers.google.cloud.operators.dataflow.DataflowRunPipelineOperator
View Docs Source
O

DataflowStartFlexTemplateOperator Deferrable

Starts a Dataflow Job with a Flex Template.

airflow.providers.google.cloud.operators.dataflow.DataflowStartFlexTemplateOperator
View Docs Source
O

DataflowStartYamlJobOperator Deferrable

Launch a Dataflow YAML job and return the result.

airflow.providers.google.cloud.operators.dataflow.DataflowStartYamlJobOperator
View Docs Source
O

DataflowStopJobOperator

Stops the job with the specified name prefix or Job ID.

airflow.providers.google.cloud.operators.dataflow.DataflowStopJobOperator
View Docs Source
O

DataflowTemplatedJobStartOperator Deferrable

Start a Dataflow job with a classic template; the parameters of the operation will be passed to the job.

airflow.providers.google.cloud.operators.dataflow.DataflowTemplatedJobStartOperator
View Docs Source
O

CloudDataFusionCreateInstanceOperator

Creates a new Data Fusion instance in the specified project and location.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionCreateInstanceOperator
View Docs Source
O

CloudDataFusionCreatePipelineOperator

Creates a Cloud Data Fusion pipeline.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionCreatePipelineOperator
View Docs Source
O

CloudDataFusionDeleteInstanceOperator

Deletes a single Date Fusion instance.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionDeleteInstanceOperator
View Docs Source
O

CloudDataFusionDeletePipelineOperator

Deletes a Cloud Data Fusion pipeline.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionDeletePipelineOperator
View Docs Source
O

CloudDataFusionGetInstanceOperator

Gets details of a single Data Fusion instance.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionGetInstanceOperator
View Docs Source
O

CloudDataFusionListPipelinesOperator

Lists Cloud Data Fusion pipelines.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionListPipelinesOperator
View Docs Source
O

CloudDataFusionRestartInstanceOperator

Restart a single Data Fusion instance.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionRestartInstanceOperator
View Docs Source
O

CloudDataFusionStartPipelineOperator Deferrable

Starts a Cloud Data Fusion pipeline. Works for both batch and stream pipelines.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionStartPipelineOperator
View Docs Source
O

CloudDataFusionStopPipelineOperator

Stops a Cloud Data Fusion pipeline. Works for both batch and stream pipelines.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionStopPipelineOperator
View Docs Source
O

CloudDataFusionUpdateInstanceOperator

Updates a single Data Fusion instance.

airflow.providers.google.cloud.operators.datafusion.CloudDataFusionUpdateInstanceOperator
View Docs Source
O

DataplexCatalogBaseOperator

Base class for all Dataplex Catalog operators.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogBaseOperator
View Docs Source
O

DataplexCatalogCreateAspectTypeOperator

Create an AspectType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogCreateAspectTypeOperator
View Docs Source
O

DataplexCatalogCreateEntryGroupOperator

Create an EntryGroup resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogCreateEntryGroupOperator
View Docs Source
O

DataplexCatalogCreateEntryOperator

Create an Entry resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogCreateEntryOperator
View Docs Source
O

DataplexCatalogCreateEntryTypeOperator

Create an EntryType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogCreateEntryTypeOperator
View Docs Source
O

DataplexCatalogDeleteAspectTypeOperator

Delete an AspectType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogDeleteAspectTypeOperator
View Docs Source
O

DataplexCatalogDeleteEntryGroupOperator

Delete an EntryGroup resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogDeleteEntryGroupOperator
View Docs Source
O

DataplexCatalogDeleteEntryOperator

Delete an Entry resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogDeleteEntryOperator
View Docs Source
O

DataplexCatalogDeleteEntryTypeOperator

Delete an EntryType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogDeleteEntryTypeOperator
View Docs Source
O

DataplexCatalogGetAspectTypeOperator

Get an AspectType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogGetAspectTypeOperator
View Docs Source
O

DataplexCatalogGetEntryGroupOperator

Get an EntryGroup resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogGetEntryGroupOperator
View Docs Source
O

DataplexCatalogGetEntryOperator

Get an Entry resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogGetEntryOperator
View Docs Source
O

DataplexCatalogGetEntryTypeOperator

Get an EntryType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogGetEntryTypeOperator
View Docs Source
O

DataplexCatalogListAspectTypesOperator

List AspectType resources.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogListAspectTypesOperator
View Docs Source
O

DataplexCatalogListEntriesOperator

List Entry resources.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogListEntriesOperator
View Docs Source
O

DataplexCatalogListEntryGroupsOperator

List EntryGroup resources.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogListEntryGroupsOperator
View Docs Source
O

DataplexCatalogListEntryTypesOperator

List EntryType resources.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogListEntryTypesOperator
View Docs Source
O

DataplexCatalogLookupEntryOperator

Look up a single Entry by name using the permission on the source system.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogLookupEntryOperator
View Docs Source
O

DataplexCatalogSearchEntriesOperator

Search for Entries matching the given query and scope.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogSearchEntriesOperator
View Docs Source
O

DataplexCatalogUpdateAspectTypeOperator

Update an AspectType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogUpdateAspectTypeOperator
View Docs Source
O

DataplexCatalogUpdateEntryGroupOperator

Update an EntryGroup resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogUpdateEntryGroupOperator
View Docs Source
O

DataplexCatalogUpdateEntryOperator

Update an Entry resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogUpdateEntryOperator
View Docs Source
O

DataplexCatalogUpdateEntryTypeOperator

Update an EntryType resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCatalogUpdateEntryTypeOperator
View Docs Source
O

DataplexCreateAssetOperator

Creates an Asset resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCreateAssetOperator
View Docs Source
O

DataplexCreateLakeOperator

Creates a lake resource within a lake.

airflow.providers.google.cloud.operators.dataplex.DataplexCreateLakeOperator
View Docs Source
O

DataplexCreateOrUpdateDataProfileScanOperator

Creates a DataScan Data Profile resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCreateOrUpdateDataProfileScanOperator
View Docs Source
O

DataplexCreateOrUpdateDataQualityScanOperator

Creates a DataScan resource.

airflow.providers.google.cloud.operators.dataplex.DataplexCreateOrUpdateDataQualityScanOperator
View Docs Source
O

DataplexCreateTaskOperator

Creates a task resource within a lake.

airflow.providers.google.cloud.operators.dataplex.DataplexCreateTaskOperator
View Docs Source
O

DataplexCreateZoneOperator

Creates a Zone resource within a Lake.

airflow.providers.google.cloud.operators.dataplex.DataplexCreateZoneOperator
View Docs Source
O

DataplexDeleteAssetOperator

Deletes an asset resource.

airflow.providers.google.cloud.operators.dataplex.DataplexDeleteAssetOperator
View Docs Source
O

DataplexDeleteDataProfileScanOperator

Deletes a DataScan DataProfile resource.

airflow.providers.google.cloud.operators.dataplex.DataplexDeleteDataProfileScanOperator
View Docs Source
O

DataplexDeleteDataQualityScanOperator

Deletes a DataScan resource.

airflow.providers.google.cloud.operators.dataplex.DataplexDeleteDataQualityScanOperator
View Docs Source
O

DataplexDeleteLakeOperator

Delete the lake resource.

airflow.providers.google.cloud.operators.dataplex.DataplexDeleteLakeOperator
View Docs Source
O

DataplexDeleteTaskOperator

Delete the task resource.

airflow.providers.google.cloud.operators.dataplex.DataplexDeleteTaskOperator
View Docs Source
O

DataplexDeleteZoneOperator

Deletes a Zone resource. All assets within a zone must be deleted before the zone can be deleted.

airflow.providers.google.cloud.operators.dataplex.DataplexDeleteZoneOperator
View Docs Source
O

DataplexGetDataProfileScanOperator

Gets a DataScan DataProfile resource.

airflow.providers.google.cloud.operators.dataplex.DataplexGetDataProfileScanOperator
View Docs Source
O

DataplexGetDataProfileScanResultOperator

Gets a DataScan Data Profile Job resource.

airflow.providers.google.cloud.operators.dataplex.DataplexGetDataProfileScanResultOperator
View Docs Source
O

DataplexGetDataQualityScanOperator

Gets a DataScan resource.

airflow.providers.google.cloud.operators.dataplex.DataplexGetDataQualityScanOperator
View Docs Source
O

DataplexGetDataQualityScanResultOperator Deferrable

Gets a Data Scan Job resource.

airflow.providers.google.cloud.operators.dataplex.DataplexGetDataQualityScanResultOperator
View Docs Source
O

DataplexGetTaskOperator

Get task resource.

airflow.providers.google.cloud.operators.dataplex.DataplexGetTaskOperator
View Docs Source
O

DataplexListTasksOperator

Lists tasks under the given lake.

airflow.providers.google.cloud.operators.dataplex.DataplexListTasksOperator
View Docs Source
O

DataplexRunDataProfileScanOperator Deferrable

Runs an on-demand execution of a DataScan Data Profile Scan.

airflow.providers.google.cloud.operators.dataplex.DataplexRunDataProfileScanOperator
View Docs Source
O

DataplexRunDataQualityScanOperator Deferrable

Runs an on-demand execution of a DataScan.

airflow.providers.google.cloud.operators.dataplex.DataplexRunDataQualityScanOperator
View Docs Source
O

DataprepCopyFlowOperator

Create a copy of the provided flow id, as well as all contained recipes.

airflow.providers.google.cloud.operators.dataprep.DataprepCopyFlowOperator
View Docs Source
O

DataprepDeleteFlowOperator

Delete the flow with provided id.

airflow.providers.google.cloud.operators.dataprep.DataprepDeleteFlowOperator
View Docs Source
O

DataprepGetJobGroupOperator

Get the specified job group.

airflow.providers.google.cloud.operators.dataprep.DataprepGetJobGroupOperator
View Docs Source
O

DataprepGetJobsForJobGroupOperator

Get information about the batch jobs within a Cloud Dataprep job.

airflow.providers.google.cloud.operators.dataprep.DataprepGetJobsForJobGroupOperator
View Docs Source
O

DataprepRunFlowOperator

Runs the flow with the provided id copy of the provided flow id.

airflow.providers.google.cloud.operators.dataprep.DataprepRunFlowOperator
View Docs Source
O

DataprepRunJobGroupOperator

Create a ``jobGroup``, which launches the specified job as the authenticated user.

airflow.providers.google.cloud.operators.dataprep.DataprepRunJobGroupOperator
View Docs Source
O

DataprocMetastoreCreateBackupOperator

Create a new backup in a given project and location.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreCreateBackupOperator
View Docs Source
O

DataprocMetastoreCreateMetadataImportOperator

Create a new MetadataImport in a given project and location.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreCreateMetadataImportOperator
View Docs Source
O

DataprocMetastoreCreateServiceOperator

Create a metastore service in a project and location.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreCreateServiceOperator
View Docs Source
O

DataprocMetastoreDeleteBackupOperator

Delete a single backup.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreDeleteBackupOperator
View Docs Source
O

DataprocMetastoreDeleteServiceOperator

Delete a single service.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreDeleteServiceOperator
View Docs Source
O

DataprocMetastoreExportMetadataOperator

Export metadata from a service.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreExportMetadataOperator
View Docs Source
O

DataprocMetastoreGetServiceOperator

Get the details of a single service.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreGetServiceOperator
View Docs Source
O

DataprocMetastoreListBackupsOperator

List backups in a service.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreListBackupsOperator
View Docs Source
O

DataprocMetastoreRestoreServiceOperator

Restore a service from a backup.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreRestoreServiceOperator
View Docs Source
O

DataprocMetastoreUpdateServiceOperator

Update the parameters of a single service.

airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreUpdateServiceOperator
View Docs Source
O

DataprocCancelOperationOperator

Cancel the batch workload resource.

airflow.providers.google.cloud.operators.dataproc.DataprocCancelOperationOperator
View Docs Source
O

DataprocCreateBatchOperator Deferrable

Create a batch workload.

airflow.providers.google.cloud.operators.dataproc.DataprocCreateBatchOperator
View Docs Source
O

DataprocCreateClusterOperator Deferrable

Create a new cluster on Google Cloud Dataproc.

airflow.providers.google.cloud.operators.dataproc.DataprocCreateClusterOperator
View Docs Source
O

DataprocCreateWorkflowTemplateOperator

Creates new workflow template.

airflow.providers.google.cloud.operators.dataproc.DataprocCreateWorkflowTemplateOperator
View Docs Source
O

DataprocDeleteBatchOperator

Delete the batch workload resource.

airflow.providers.google.cloud.operators.dataproc.DataprocDeleteBatchOperator
View Docs Source
O

DataprocDeleteClusterOperator Deferrable

Delete a cluster in a project.

airflow.providers.google.cloud.operators.dataproc.DataprocDeleteClusterOperator
View Docs Source
O

DataprocDiagnoseClusterOperator Deferrable

Diagnose a cluster in a project.

airflow.providers.google.cloud.operators.dataproc.DataprocDiagnoseClusterOperator
View Docs Source
O

DataprocGetBatchOperator

Get the batch workload resource representation.

airflow.providers.google.cloud.operators.dataproc.DataprocGetBatchOperator
View Docs Source
O

DataprocInstantiateInlineWorkflowTemplateOperator Deferrable

Instantiate a WorkflowTemplate Inline on Google Cloud Dataproc.

airflow.providers.google.cloud.operators.dataproc.DataprocInstantiateInlineWorkflowTemplateOperator
View Docs Source
O

DataprocInstantiateWorkflowTemplateOperator Deferrable

Instantiate a WorkflowTemplate on Google Cloud Dataproc.

airflow.providers.google.cloud.operators.dataproc.DataprocInstantiateWorkflowTemplateOperator
View Docs Source
O

DataprocJobBaseOperator Deferrable

Base class for operators that launch job on DataProc.

airflow.providers.google.cloud.operators.dataproc.DataprocJobBaseOperator
View Docs Source
O

DataprocListBatchesOperator

List batch workloads.

airflow.providers.google.cloud.operators.dataproc.DataprocListBatchesOperator
View Docs Source
O

DataprocStartClusterOperator

Start a cluster in a project.

airflow.providers.google.cloud.operators.dataproc.DataprocStartClusterOperator
View Docs Source
O

DataprocStopClusterOperator

Stop a cluster in a project.

airflow.providers.google.cloud.operators.dataproc.DataprocStopClusterOperator
View Docs Source
O

DataprocSubmitJobOperator Deferrable

Submit a job to a cluster.

airflow.providers.google.cloud.operators.dataproc.DataprocSubmitJobOperator
View Docs Source
O

DataprocUpdateClusterOperator Deferrable

Update a cluster in a project.

airflow.providers.google.cloud.operators.dataproc.DataprocUpdateClusterOperator
View Docs Source
O

CloudDatastoreAllocateIdsOperator

Allocate IDs for incomplete keys. Return list of keys.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreAllocateIdsOperator
View Docs Source
O

CloudDatastoreBeginTransactionOperator

Begins a new transaction. Returns a transaction handle.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreBeginTransactionOperator
View Docs Source
O

CloudDatastoreCommitOperator

Commit a transaction, optionally creating, deleting or modifying some entities.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreCommitOperator
View Docs Source
O

CloudDatastoreDeleteOperationOperator

Deletes the long-running operation.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreDeleteOperationOperator
View Docs Source
O

CloudDatastoreExportEntitiesOperator

Export entities from Google Cloud Datastore to Cloud Storage.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreExportEntitiesOperator
View Docs Source
O

CloudDatastoreGetOperationOperator

Gets the latest state of a long-running operation.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreGetOperationOperator
View Docs Source
O

CloudDatastoreImportEntitiesOperator

Import entities from Cloud Storage to Google Cloud Datastore.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreImportEntitiesOperator
View Docs Source
O

CloudDatastoreRollbackOperator

Roll back a transaction.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreRollbackOperator
View Docs Source
O

CloudDatastoreRunQueryOperator

Run a query for entities. Returns the batch of query results.

airflow.providers.google.cloud.operators.datastore.CloudDatastoreRunQueryOperator
View Docs Source
O

CloudDLPCancelDLPJobOperator

Starts asynchronous cancellation on a long-running DlpJob.

airflow.providers.google.cloud.operators.dlp.CloudDLPCancelDLPJobOperator
View Docs Source
O

CloudDLPCreateDLPJobOperator

Creates a new job to inspect storage or calculate risk metrics.

airflow.providers.google.cloud.operators.dlp.CloudDLPCreateDLPJobOperator
View Docs Source
O

CloudDLPCreateDeidentifyTemplateOperator

Create a deidentify template to reuse frequently-used configurations for content, images, and storage.

airflow.providers.google.cloud.operators.dlp.CloudDLPCreateDeidentifyTemplateOperator
View Docs Source
O

CloudDLPCreateInspectTemplateOperator

Create an InspectTemplate to reuse frequently-used configurations for content, images, and storage.

airflow.providers.google.cloud.operators.dlp.CloudDLPCreateInspectTemplateOperator
View Docs Source
O

CloudDLPCreateJobTriggerOperator

Create a job trigger to run DLP actions such as scanning storage for sensitive info on a set schedule.

airflow.providers.google.cloud.operators.dlp.CloudDLPCreateJobTriggerOperator
View Docs Source
O

CloudDLPCreateStoredInfoTypeOperator

Creates a pre-built stored infoType to be used for inspection.

airflow.providers.google.cloud.operators.dlp.CloudDLPCreateStoredInfoTypeOperator
View Docs Source
O

CloudDLPDeidentifyContentOperator

De-identifies potentially sensitive info from a content item; limits input size and output size.

airflow.providers.google.cloud.operators.dlp.CloudDLPDeidentifyContentOperator
View Docs Source
O

CloudDLPDeleteDLPJobOperator

Deletes a long-running DlpJob.

airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteDLPJobOperator
View Docs Source
O

CloudDLPDeleteDeidentifyTemplateOperator

Deletes a DeidentifyTemplate.

airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteDeidentifyTemplateOperator
View Docs Source
O

CloudDLPDeleteInspectTemplateOperator

Deletes an InspectTemplate.

airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteInspectTemplateOperator
View Docs Source
O

CloudDLPDeleteJobTriggerOperator

Deletes a job trigger.

airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteJobTriggerOperator
View Docs Source
O

CloudDLPDeleteStoredInfoTypeOperator

Deletes a stored infoType.

airflow.providers.google.cloud.operators.dlp.CloudDLPDeleteStoredInfoTypeOperator
View Docs Source
O

CloudDLPGetDLPJobOperator

Gets the latest state of a long-running DlpJob.

airflow.providers.google.cloud.operators.dlp.CloudDLPGetDLPJobOperator
View Docs Source
O

CloudDLPGetDLPJobTriggerOperator

Gets a job trigger.

airflow.providers.google.cloud.operators.dlp.CloudDLPGetDLPJobTriggerOperator
View Docs Source
O

CloudDLPGetDeidentifyTemplateOperator

Gets a DeidentifyTemplate.

airflow.providers.google.cloud.operators.dlp.CloudDLPGetDeidentifyTemplateOperator
View Docs Source
O

CloudDLPGetInspectTemplateOperator

Gets an InspectTemplate.

airflow.providers.google.cloud.operators.dlp.CloudDLPGetInspectTemplateOperator
View Docs Source
O

CloudDLPGetStoredInfoTypeOperator

Gets a stored infoType.

airflow.providers.google.cloud.operators.dlp.CloudDLPGetStoredInfoTypeOperator
View Docs Source
O

CloudDLPInspectContentOperator

Finds potentially sensitive info in content; limits input size, processing time, and output size.

airflow.providers.google.cloud.operators.dlp.CloudDLPInspectContentOperator
View Docs Source
O

CloudDLPListDLPJobsOperator

Lists DlpJobs that match the specified filter in the request.

airflow.providers.google.cloud.operators.dlp.CloudDLPListDLPJobsOperator
View Docs Source
O

CloudDLPListDeidentifyTemplatesOperator

Lists DeidentifyTemplates.

airflow.providers.google.cloud.operators.dlp.CloudDLPListDeidentifyTemplatesOperator
View Docs Source
O

CloudDLPListInfoTypesOperator

Returns a list of the sensitive information types that the DLP API supports.

airflow.providers.google.cloud.operators.dlp.CloudDLPListInfoTypesOperator
View Docs Source
O

CloudDLPListInspectTemplatesOperator

Lists InspectTemplates.

airflow.providers.google.cloud.operators.dlp.CloudDLPListInspectTemplatesOperator
View Docs Source
O

CloudDLPListJobTriggersOperator

Lists job triggers.

airflow.providers.google.cloud.operators.dlp.CloudDLPListJobTriggersOperator
View Docs Source
O

CloudDLPListStoredInfoTypesOperator

Lists stored infoTypes.

airflow.providers.google.cloud.operators.dlp.CloudDLPListStoredInfoTypesOperator
View Docs Source
O

CloudDLPRedactImageOperator

Redacts potentially sensitive info from an image; limits input size, processing time, and output size.

airflow.providers.google.cloud.operators.dlp.CloudDLPRedactImageOperator
View Docs Source
O

CloudDLPReidentifyContentOperator

Re-identifies content that has been de-identified.

airflow.providers.google.cloud.operators.dlp.CloudDLPReidentifyContentOperator
View Docs Source
O

CloudDLPUpdateDeidentifyTemplateOperator

Updates the DeidentifyTemplate.

airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateDeidentifyTemplateOperator
View Docs Source
O

CloudDLPUpdateInspectTemplateOperator

Updates the InspectTemplate.

airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateInspectTemplateOperator
View Docs Source
O

CloudDLPUpdateJobTriggerOperator

Updates a job trigger.

airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateJobTriggerOperator
View Docs Source
O

CloudDLPUpdateStoredInfoTypeOperator

Updates the stored infoType by creating a new version.

airflow.providers.google.cloud.operators.dlp.CloudDLPUpdateStoredInfoTypeOperator
View Docs Source
O

CloudFunctionDeleteFunctionOperator

Deletes the specified function from Google Cloud Functions.

airflow.providers.google.cloud.operators.functions.CloudFunctionDeleteFunctionOperator
View Docs Source
O

CloudFunctionDeployFunctionOperator

Create or update a function in Google Cloud Functions.

airflow.providers.google.cloud.operators.functions.CloudFunctionDeployFunctionOperator
View Docs Source
O

CloudFunctionInvokeFunctionOperator

Invokes a deployed Cloud Function. To be used for testing purposes as very limited traffic is allowed.

airflow.providers.google.cloud.operators.functions.CloudFunctionInvokeFunctionOperator
View Docs Source
O

GCSBucketAddIamBindingOperator

Adds a member to an IAM role binding on the specified bucket.

airflow.providers.google.cloud.operators.gcs.GCSBucketAddIamBindingOperator
View Docs Source
O

GCSBucketCreateAclEntryOperator

Creates a new ACL entry on the specified bucket.

airflow.providers.google.cloud.operators.gcs.GCSBucketCreateAclEntryOperator
View Docs Source
O

GCSCreateBucketOperator

Creates a new bucket.

airflow.providers.google.cloud.operators.gcs.GCSCreateBucketOperator
View Docs Source
O

GCSDeleteBucketOperator

Deletes bucket from a Google Cloud Storage.

airflow.providers.google.cloud.operators.gcs.GCSDeleteBucketOperator
View Docs Source
O

GCSDeleteObjectsOperator

Deletes objects from a list or all objects matching a prefix from a Google Cloud Storage bucket.

airflow.providers.google.cloud.operators.gcs.GCSDeleteObjectsOperator
View Docs Source
O

GCSFileTransformOperator

Copies data from a source GCS location to a temporary location on the local filesystem.

airflow.providers.google.cloud.operators.gcs.GCSFileTransformOperator
View Docs Source
O

GCSListObjectsOperator

List all objects from the bucket filtered by given string prefix and delimiter in name or match_glob.

airflow.providers.google.cloud.operators.gcs.GCSListObjectsOperator
View Docs Source
O

GCSObjectCreateAclEntryOperator

Creates a new ACL entry on the specified object.

airflow.providers.google.cloud.operators.gcs.GCSObjectCreateAclEntryOperator
View Docs Source
O

GCSSynchronizeBucketsOperator

Synchronizes the contents of the buckets or bucket's directories in the Google Cloud Services.

airflow.providers.google.cloud.operators.gcs.GCSSynchronizeBucketsOperator
View Docs Source
O

GCSTimeSpanFileTransformOperator

Copy objects that were modified during a time span, run a transform, and upload results to a bucket.

airflow.providers.google.cloud.operators.gcs.GCSTimeSpanFileTransformOperator
View Docs Source
O

GKECreateClusterOperator Deferrable

Create a Google Kubernetes Engine Cluster of specified dimensions and wait until the cluster is created.

airflow.providers.google.cloud.operators.kubernetes_engine.GKECreateClusterOperator
View Docs Source
O

GKECreateCustomResourceOperator

Create a resource in the specified Google Kubernetes Engine cluster.

airflow.providers.google.cloud.operators.kubernetes_engine.GKECreateCustomResourceOperator
View Docs Source
O

GKEDeleteClusterOperator Deferrable

Deletes the cluster, including the Kubernetes endpoint and all worker nodes.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEDeleteClusterOperator
View Docs Source
O

GKEDeleteCustomResourceOperator

Delete a resource in the specified Google Kubernetes Engine cluster.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEDeleteCustomResourceOperator
View Docs Source
O

GKEDeleteJobOperator

Delete a Kubernetes job in the specified Google Kubernetes Engine cluster.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEDeleteJobOperator
View Docs Source
O

GKEDescribeJobOperator

Retrieve information about Job by given name.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEDescribeJobOperator
View Docs Source
O

GKEListJobsOperator

Retrieve list of Jobs.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEListJobsOperator
View Docs Source
O

GKEPodExecOperator

Execute a command in a running container of an existing Pod on Google Kubernetes Engine.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEPodExecOperator
View Docs Source
O

GKEResumeJobOperator

Resume Job by given name.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEResumeJobOperator
View Docs Source
O

GKEStartJobOperator Deferrable

Executes a Kubernetes job in the specified Google Kubernetes Engine cluster.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEStartJobOperator
View Docs Source
O

GKEStartKueueInsideClusterOperator

Installs Kueue of specific version inside Cluster.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEStartKueueInsideClusterOperator
View Docs Source
O

GKEStartKueueJobOperator Deferrable

Executes a Kubernetes Job in Kueue in the specified Google Kubernetes Engine cluster.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEStartKueueJobOperator
View Docs Source
O

GKEStartPodOperator Durable Deferrable

Executes a task in a Kubernetes pod in the specified Google Kubernetes Engine cluster.

airflow.providers.google.cloud.operators.kubernetes_engine.GKEStartPodOperator
View Docs Source
O

GKESuspendJobOperator

Suspend Job by given name.

airflow.providers.google.cloud.operators.kubernetes_engine.GKESuspendJobOperator
View Docs Source
O

CloudNaturalLanguageAnalyzeEntitiesOperator

Finds named entities in the text along with various properties.

airflow.providers.google.cloud.operators.natural_language.CloudNaturalLanguageAnalyzeEntitiesOperator
View Docs Source
O

CloudNaturalLanguageAnalyzeEntitySentimentOperator

Similar to AnalyzeEntities, also analyzes sentiment associated with each entity and its mentions.

airflow.providers.google.cloud.operators.natural_language.CloudNaturalLanguageAnalyzeEntitySentimentOperator
View Docs Source
O

CloudNaturalLanguageAnalyzeSentimentOperator

Analyzes the sentiment of the provided text.

airflow.providers.google.cloud.operators.natural_language.CloudNaturalLanguageAnalyzeSentimentOperator
View Docs Source
O

CloudNaturalLanguageClassifyTextOperator

Classifies a document into categories.

airflow.providers.google.cloud.operators.natural_language.CloudNaturalLanguageClassifyTextOperator
View Docs Source
O

PubSubCreateSubscriptionOperator

Create a PubSub subscription.

airflow.providers.google.cloud.operators.pubsub.PubSubCreateSubscriptionOperator
View Docs Source
O

PubSubCreateTopicOperator

Create a PubSub topic.

airflow.providers.google.cloud.operators.pubsub.PubSubCreateTopicOperator
View Docs Source
O

PubSubDeleteSubscriptionOperator

Delete a PubSub subscription.

airflow.providers.google.cloud.operators.pubsub.PubSubDeleteSubscriptionOperator
View Docs Source
O

PubSubDeleteTopicOperator

Delete a PubSub topic.

airflow.providers.google.cloud.operators.pubsub.PubSubDeleteTopicOperator
View Docs Source
O

PubSubPublishMessageOperator

Publish messages to a PubSub topic.

airflow.providers.google.cloud.operators.pubsub.PubSubPublishMessageOperator
View Docs Source
O

PubSubPullOperator Deferrable

Pulls messages from a PubSub subscription and passes them through XCom.

airflow.providers.google.cloud.operators.pubsub.PubSubPullOperator
View Docs Source
O

SpannerDeleteDatabaseInstanceOperator

Deletes a Cloud Spanner database.

airflow.providers.google.cloud.operators.spanner.SpannerDeleteDatabaseInstanceOperator
View Docs Source
O

SpannerDeleteInstanceOperator

Delete a Cloud Spanner instance; if an instance does not exist, no action is taken and the task succeeds.

airflow.providers.google.cloud.operators.spanner.SpannerDeleteInstanceOperator
View Docs Source
O

SpannerDeployDatabaseInstanceOperator

Creates a new Cloud Spanner database; if database exists, the operator does nothing.

airflow.providers.google.cloud.operators.spanner.SpannerDeployDatabaseInstanceOperator
View Docs Source
O

SpannerDeployInstanceOperator

Create or update a Cloud Spanner instance.

airflow.providers.google.cloud.operators.spanner.SpannerDeployInstanceOperator
View Docs Source
O

SpannerQueryDatabaseInstanceOperator

Executes an arbitrary DML query (INSERT, UPDATE, DELETE).

airflow.providers.google.cloud.operators.spanner.SpannerQueryDatabaseInstanceOperator
View Docs Source
O

SpannerUpdateDatabaseInstanceOperator

Updates a Cloud Spanner database with the specified DDL statement.

airflow.providers.google.cloud.operators.spanner.SpannerUpdateDatabaseInstanceOperator
View Docs Source
O

CloudSpeechToTextRecognizeSpeechOperator

Recognizes speech from audio file and returns it as text.

airflow.providers.google.cloud.operators.speech_to_text.CloudSpeechToTextRecognizeSpeechOperator
View Docs Source
O

CloudMonitoringDeleteAlertOperator

Deletes an alerting policy.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringDeleteAlertOperator
View Docs Source
O

CloudMonitoringDeleteNotificationChannelOperator

Deletes a notification channel.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringDeleteNotificationChannelOperator
View Docs Source
O

CloudMonitoringDisableAlertPoliciesOperator

Disables one or more enabled alerting policies identified by filter parameter.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringDisableAlertPoliciesOperator
View Docs Source
O

CloudMonitoringDisableNotificationChannelsOperator

Disables one or more enabled notification channels identified by filter parameter.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringDisableNotificationChannelsOperator
View Docs Source
O

CloudMonitoringEnableAlertPoliciesOperator

Enables one or more disabled alerting policies identified by filter parameter.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringEnableAlertPoliciesOperator
View Docs Source
O

CloudMonitoringEnableNotificationChannelsOperator

Enables one or more disabled notification channels identified by filter parameter.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringEnableNotificationChannelsOperator
View Docs Source
O

CloudMonitoringListAlertPoliciesOperator

Fetches all the Alert Policies identified by the filter passed as filter parameter.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringListAlertPoliciesOperator
View Docs Source
O

CloudMonitoringListNotificationChannelsOperator

Fetches all the Notification Channels identified by the filter passed as filter parameter.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringListNotificationChannelsOperator
View Docs Source
O

CloudMonitoringUpsertAlertOperator

Creates a new alert or updates an existing policy identified by the name field in the alerts parameter.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringUpsertAlertOperator
View Docs Source
O

CloudMonitoringUpsertNotificationChannelOperator

Create a new notification or updates an existing notification channel.

airflow.providers.google.cloud.operators.cloud_monitoring.CloudMonitoringUpsertNotificationChannelOperator
View Docs Source
O

CloudTasksQueueCreateOperator

Creates a queue in Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueueCreateOperator
View Docs Source
O

CloudTasksQueueDeleteOperator

Deletes a queue from Cloud Tasks, even if it has tasks in it.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueueDeleteOperator
View Docs Source
O

CloudTasksQueueGetOperator

Gets a queue from Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueueGetOperator
View Docs Source
O

CloudTasksQueuePauseOperator

Pauses a queue in Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueuePauseOperator
View Docs Source
O

CloudTasksQueuePurgeOperator

Purges a queue by deleting all of its tasks from Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueuePurgeOperator
View Docs Source
O

CloudTasksQueueResumeOperator

Resumes a queue in Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueueResumeOperator
View Docs Source
O

CloudTasksQueueUpdateOperator

Updates a queue in Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueueUpdateOperator
View Docs Source
O

CloudTasksQueuesListOperator

Lists queues from Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksQueuesListOperator
View Docs Source
O

CloudTasksTaskCreateOperator

Creates a task in Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksTaskCreateOperator
View Docs Source
O

CloudTasksTaskDeleteOperator

Deletes a task from Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksTaskDeleteOperator
View Docs Source
O

CloudTasksTaskGetOperator

Gets a task from Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksTaskGetOperator
View Docs Source
O

CloudTasksTaskRunOperator

Forces to run a task in Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksTaskRunOperator
View Docs Source
O

CloudTasksTasksListOperator

Lists the tasks in Cloud Tasks.

airflow.providers.google.cloud.operators.tasks.CloudTasksTasksListOperator
View Docs Source
O

CloudTextToSpeechSynthesizeOperator

Synthesizes text to speech and stores it in Google Cloud Storage.

airflow.providers.google.cloud.operators.text_to_speech.CloudTextToSpeechSynthesizeOperator
View Docs Source
O

CloudTranslateSpeechOperator

Recognizes speech in audio input and translates it.

airflow.providers.google.cloud.operators.translate_speech.CloudTranslateSpeechOperator
View Docs Source
O

CloudTranslateTextOperator

Translate a string or list of strings.

airflow.providers.google.cloud.operators.translate.CloudTranslateTextOperator
View Docs Source
O

TranslateCreateDatasetOperator

Create a Google Cloud Translate dataset.

airflow.providers.google.cloud.operators.translate.TranslateCreateDatasetOperator
View Docs Source
O

TranslateCreateGlossaryOperator

Creates a Google Cloud Translation Glossary.

airflow.providers.google.cloud.operators.translate.TranslateCreateGlossaryOperator
View Docs Source
O

TranslateCreateModelOperator

Creates a Google Cloud Translate model.

airflow.providers.google.cloud.operators.translate.TranslateCreateModelOperator
View Docs Source
O

TranslateDatasetsListOperator

Get a list of native Google Cloud Translation datasets in a project.

airflow.providers.google.cloud.operators.translate.TranslateDatasetsListOperator
View Docs Source
O

TranslateDeleteDatasetOperator

Delete translation dataset and all of its contents.

airflow.providers.google.cloud.operators.translate.TranslateDeleteDatasetOperator
View Docs Source
O

TranslateDeleteGlossaryOperator

Delete a Google Cloud Translation Glossary.

airflow.providers.google.cloud.operators.translate.TranslateDeleteGlossaryOperator
View Docs Source
O

TranslateDeleteModelOperator

Delete translation model and all of its contents.

airflow.providers.google.cloud.operators.translate.TranslateDeleteModelOperator
View Docs Source
O

TranslateDocumentBatchOperator

Translate documents provided via input and output configurations.

airflow.providers.google.cloud.operators.translate.TranslateDocumentBatchOperator
View Docs Source
O

TranslateDocumentOperator

Translate document provided.

airflow.providers.google.cloud.operators.translate.TranslateDocumentOperator
View Docs Source
O

TranslateImportDataOperator

Import data to the translation dataset.

airflow.providers.google.cloud.operators.translate.TranslateImportDataOperator
View Docs Source
O

TranslateListGlossariesOperator

Get a list of translation glossaries in a project.

airflow.providers.google.cloud.operators.translate.TranslateListGlossariesOperator
View Docs Source
O

TranslateModelsListOperator

Get a list of native Google Cloud Translation models in a project.

airflow.providers.google.cloud.operators.translate.TranslateModelsListOperator
View Docs Source
O

TranslateTextBatchOperator

Translate large volumes of text content, by the inputs provided.

airflow.providers.google.cloud.operators.translate.TranslateTextBatchOperator
View Docs Source
O

TranslateTextOperator

Translate text content of moderate amount, for larger volumes of text please use the TranslateTextBatchOperator.

airflow.providers.google.cloud.operators.translate.TranslateTextOperator
View Docs Source
O

TranslateUpdateGlossaryOperator

Update glossary item with values provided.

airflow.providers.google.cloud.operators.translate.TranslateUpdateGlossaryOperator
View Docs Source
O

CloudVideoIntelligenceDetectVideoExplicitContentOperator

Performs video annotation, annotating explicit content.

airflow.providers.google.cloud.operators.video_intelligence.CloudVideoIntelligenceDetectVideoExplicitContentOperator
View Docs Source
O

CloudVideoIntelligenceDetectVideoLabelsOperator

Performs video annotation, annotating video labels.

airflow.providers.google.cloud.operators.video_intelligence.CloudVideoIntelligenceDetectVideoLabelsOperator
View Docs Source
O

CloudVideoIntelligenceDetectVideoShotsOperator

Performs video annotation, annotating video shots.

airflow.providers.google.cloud.operators.video_intelligence.CloudVideoIntelligenceDetectVideoShotsOperator
View Docs Source
O

CloudVisionAddProductToProductSetOperator

Add a Product to the specified ProductSet.

airflow.providers.google.cloud.operators.vision.CloudVisionAddProductToProductSetOperator
View Docs Source
O

CloudVisionCreateProductOperator

Create and return a new product resource.

airflow.providers.google.cloud.operators.vision.CloudVisionCreateProductOperator
View Docs Source
O

CloudVisionCreateProductSetOperator

Create a new ProductSet resource.

airflow.providers.google.cloud.operators.vision.CloudVisionCreateProductSetOperator
View Docs Source
O

CloudVisionCreateReferenceImageOperator

Create and return a new ReferenceImage ID resource.

airflow.providers.google.cloud.operators.vision.CloudVisionCreateReferenceImageOperator
View Docs Source
O

CloudVisionDeleteProductOperator

Permanently delete a product and its reference images.

airflow.providers.google.cloud.operators.vision.CloudVisionDeleteProductOperator
View Docs Source
O

CloudVisionDeleteProductSetOperator

Permanently deletes a ``ProductSet``.

airflow.providers.google.cloud.operators.vision.CloudVisionDeleteProductSetOperator
View Docs Source
O

CloudVisionDeleteReferenceImageOperator

Delete a ReferenceImage ID resource.

airflow.providers.google.cloud.operators.vision.CloudVisionDeleteReferenceImageOperator
View Docs Source
O

CloudVisionDetectImageLabelsOperator

Detect Document Text in the image.

airflow.providers.google.cloud.operators.vision.CloudVisionDetectImageLabelsOperator
View Docs Source
O

CloudVisionDetectImageSafeSearchOperator

Detect Document Text in the image.

airflow.providers.google.cloud.operators.vision.CloudVisionDetectImageSafeSearchOperator
View Docs Source
O

CloudVisionDetectTextOperator

Detect Text in the image.

airflow.providers.google.cloud.operators.vision.CloudVisionDetectTextOperator
View Docs Source
O

CloudVisionGetProductOperator

Get information associated with a ``Product``.

airflow.providers.google.cloud.operators.vision.CloudVisionGetProductOperator
View Docs Source
O

CloudVisionGetProductSetOperator

Get information associated with a ProductSet.

airflow.providers.google.cloud.operators.vision.CloudVisionGetProductSetOperator
View Docs Source
O

CloudVisionImageAnnotateOperator

Run image detection and annotation for an image or a batch of images.

airflow.providers.google.cloud.operators.vision.CloudVisionImageAnnotateOperator
View Docs Source
O

CloudVisionRemoveProductFromProductSetOperator

Remove a Product from the specified ProductSet.

airflow.providers.google.cloud.operators.vision.CloudVisionRemoveProductFromProductSetOperator
View Docs Source
O

CloudVisionTextDetectOperator

Detect Document Text in the image.

airflow.providers.google.cloud.operators.vision.CloudVisionTextDetectOperator
View Docs Source
O

CloudVisionUpdateProductOperator

Make changes to a Product resource.

airflow.providers.google.cloud.operators.vision.CloudVisionUpdateProductOperator
View Docs Source
O

CloudVisionUpdateProductSetOperator

Make changes to a `ProductSet` resource.

airflow.providers.google.cloud.operators.vision.CloudVisionUpdateProductSetOperator
View Docs Source
O

WorkflowsCancelExecutionOperator

Cancels an execution using the given ``workflow_id`` and ``execution_id``.

airflow.providers.google.cloud.operators.workflows.WorkflowsCancelExecutionOperator
View Docs Source
O

WorkflowsCreateExecutionOperator

Creates a new execution using the latest revision of the given workflow.

airflow.providers.google.cloud.operators.workflows.WorkflowsCreateExecutionOperator
View Docs Source
O

WorkflowsCreateWorkflowOperator

Creates a new workflow.

airflow.providers.google.cloud.operators.workflows.WorkflowsCreateWorkflowOperator
View Docs Source
O

WorkflowsDeleteWorkflowOperator

Delete a workflow with the specified name and all running executions of the workflow.

airflow.providers.google.cloud.operators.workflows.WorkflowsDeleteWorkflowOperator
View Docs Source
O

WorkflowsGetExecutionOperator

Returns an execution for the given ``workflow_id`` and ``execution_id``.

airflow.providers.google.cloud.operators.workflows.WorkflowsGetExecutionOperator
View Docs Source
O

WorkflowsGetWorkflowOperator

Gets details of a single Workflow.

airflow.providers.google.cloud.operators.workflows.WorkflowsGetWorkflowOperator
View Docs Source
O

WorkflowsListExecutionsOperator

Returns a list of executions which belong to the workflow with the given name.

airflow.providers.google.cloud.operators.workflows.WorkflowsListExecutionsOperator
View Docs Source
O

WorkflowsListWorkflowsOperator

Lists Workflows in a given project and location; the default order is not specified.

airflow.providers.google.cloud.operators.workflows.WorkflowsListWorkflowsOperator
View Docs Source
O

WorkflowsUpdateWorkflowOperator

Updates an existing workflow.

airflow.providers.google.cloud.operators.workflows.WorkflowsUpdateWorkflowOperator
View Docs Source
O

CloudFirestoreExportDatabaseOperator

Export documents from Google Cloud Firestore to another storage system, such as Google Cloud Storage.

airflow.providers.google.firebase.operators.firestore.CloudFirestoreExportDatabaseOperator
View Docs Source
O

GoogleAnalyticsAdminCreateDataStreamOperator

Creates Data stream.

airflow.providers.google.marketing_platform.operators.analytics_admin.GoogleAnalyticsAdminCreateDataStreamOperator
View Docs Source
O

GoogleAnalyticsAdminCreatePropertyOperator

Creates property.

airflow.providers.google.marketing_platform.operators.analytics_admin.GoogleAnalyticsAdminCreatePropertyOperator
View Docs Source
O

GoogleAnalyticsAdminDeleteDataStreamOperator

Deletes Data stream.

airflow.providers.google.marketing_platform.operators.analytics_admin.GoogleAnalyticsAdminDeleteDataStreamOperator
View Docs Source
O

GoogleAnalyticsAdminDeletePropertyOperator

Soft-delete property.

airflow.providers.google.marketing_platform.operators.analytics_admin.GoogleAnalyticsAdminDeletePropertyOperator
View Docs Source
O

GoogleAnalyticsAdminGetGoogleAdsLinkOperator

Gets a Google Ads link associated with a given property.

airflow.providers.google.marketing_platform.operators.analytics_admin.GoogleAnalyticsAdminGetGoogleAdsLinkOperator
View Docs Source
O

GoogleAnalyticsAdminListAccountsOperator

Lists all accounts to which the user has access.

airflow.providers.google.marketing_platform.operators.analytics_admin.GoogleAnalyticsAdminListAccountsOperator
View Docs Source
O

GoogleAnalyticsAdminListGoogleAdsLinksOperator

Lists all Google Ads links associated with a given property.

airflow.providers.google.marketing_platform.operators.analytics_admin.GoogleAnalyticsAdminListGoogleAdsLinksOperator
View Docs Source
O

GoogleCampaignManagerBatchInsertConversionsOperator

Inserts conversions.

airflow.providers.google.marketing_platform.operators.campaign_manager.GoogleCampaignManagerBatchInsertConversionsOperator
View Docs Source
O

GoogleCampaignManagerBatchUpdateConversionsOperator

Updates existing conversions.

airflow.providers.google.marketing_platform.operators.campaign_manager.GoogleCampaignManagerBatchUpdateConversionsOperator
View Docs Source
O

GoogleCampaignManagerDeleteReportOperator

Deletes a report by its ID.

airflow.providers.google.marketing_platform.operators.campaign_manager.GoogleCampaignManagerDeleteReportOperator
View Docs Source
O

GoogleCampaignManagerDownloadReportOperator

Retrieves a report and uploads it to GCS bucket.

airflow.providers.google.marketing_platform.operators.campaign_manager.GoogleCampaignManagerDownloadReportOperator
View Docs Source
O

GoogleCampaignManagerInsertReportOperator

Creates a report.

airflow.providers.google.marketing_platform.operators.campaign_manager.GoogleCampaignManagerInsertReportOperator
View Docs Source
O

GoogleCampaignManagerRunReportOperator

Runs a report.

airflow.providers.google.marketing_platform.operators.campaign_manager.GoogleCampaignManagerRunReportOperator
View Docs Source
O

GoogleDisplayVideo360CreateSDFDownloadTaskOperator

Creates an SDF operation task.

airflow.providers.google.marketing_platform.operators.display_video.GoogleDisplayVideo360CreateSDFDownloadTaskOperator
View Docs Source
O

GoogleDisplayVideo360SDFtoGCSOperator

Download SDF media and save it in the Google Cloud Storage.

airflow.providers.google.marketing_platform.operators.display_video.GoogleDisplayVideo360SDFtoGCSOperator
View Docs Source
O

GoogleSearchAdsGetCustomColumnOperator

Retrieve details of a custom column for the given customer_id and campaign_id.

airflow.providers.google.marketing_platform.operators.search_ads.GoogleSearchAdsGetCustomColumnOperator
View Docs Source
O

GoogleSearchAdsGetFieldOperator

Retrieve metadata for a resource or a field.

airflow.providers.google.marketing_platform.operators.search_ads.GoogleSearchAdsGetFieldOperator
View Docs Source
O

GoogleSearchAdsListCustomColumnsOperator

List all custom columns.

airflow.providers.google.marketing_platform.operators.search_ads.GoogleSearchAdsListCustomColumnsOperator
View Docs Source
O

GoogleSearchAdsSearchFieldsOperator

Retrieve metadata for resource(s) or field(s) by the query syntax.

airflow.providers.google.marketing_platform.operators.search_ads.GoogleSearchAdsSearchFieldsOperator
View Docs Source
O

GoogleSearchAdsSearchOperator

Search a report by query.

airflow.providers.google.marketing_platform.operators.search_ads.GoogleSearchAdsSearchOperator
View Docs Source
O

GoogleSheetsCreateSpreadsheetOperator

Creates a new spreadsheet.

airflow.providers.google.suite.operators.sheets.GoogleSheetsCreateSpreadsheetOperator
View Docs Source
O

LevelDBOperator

Execute command in LevelDB.

airflow.providers.google.leveldb.operators.leveldb.LevelDBOperator
View Docs Source
O

CreateDatasetOperator

Creates a Dataset.

airflow.providers.google.cloud.operators.vertex_ai.dataset.CreateDatasetOperator
View Docs Source
O

DeleteDatasetOperator

Deletes a Dataset.

airflow.providers.google.cloud.operators.vertex_ai.dataset.DeleteDatasetOperator
View Docs Source
O

ExportDataOperator

Exports data from a Dataset.

airflow.providers.google.cloud.operators.vertex_ai.dataset.ExportDataOperator
View Docs Source
O

GetDatasetOperator

Get a Dataset.

airflow.providers.google.cloud.operators.vertex_ai.dataset.GetDatasetOperator
View Docs Source
O

ImportDataOperator

Imports data into a Dataset.

airflow.providers.google.cloud.operators.vertex_ai.dataset.ImportDataOperator
View Docs Source
O

ListDatasetsOperator

Lists Datasets in a Location.

airflow.providers.google.cloud.operators.vertex_ai.dataset.ListDatasetsOperator
View Docs Source
O

UpdateDatasetOperator

Updates a Dataset.

airflow.providers.google.cloud.operators.vertex_ai.dataset.UpdateDatasetOperator
View Docs Source
O

CreateCustomContainerTrainingJobOperator Deferrable

Create Custom Container Training job.

airflow.providers.google.cloud.operators.vertex_ai.custom_job.CreateCustomContainerTrainingJobOperator
View Docs Source
O

CreateCustomJobOperator Deferrable

Create a CustomJob. A created CustomJob right away will be attempted to be run.

airflow.providers.google.cloud.operators.vertex_ai.custom_job.CreateCustomJobOperator
View Docs Source
O

CreateCustomPythonPackageTrainingJobOperator Deferrable

Create Custom Python Package Training job.

airflow.providers.google.cloud.operators.vertex_ai.custom_job.CreateCustomPythonPackageTrainingJobOperator
View Docs Source
O

CreateCustomTrainingJobOperator Deferrable

Create a Custom Training Job pipeline.

airflow.providers.google.cloud.operators.vertex_ai.custom_job.CreateCustomTrainingJobOperator
View Docs Source
O

CustomTrainingJobBaseOperator

The base class for operators that launch Custom jobs on VertexAI.

airflow.providers.google.cloud.operators.vertex_ai.custom_job.CustomTrainingJobBaseOperator
View Docs Source
O

DeleteCustomTrainingJobOperator

Deletes a CustomTrainingJob, CustomPythonTrainingJob, or CustomContainerTrainingJob.

airflow.providers.google.cloud.operators.vertex_ai.custom_job.DeleteCustomTrainingJobOperator
View Docs Source
O

ListCustomTrainingJobOperator

Lists CustomTrainingJob, CustomPythonTrainingJob, or CustomContainerTrainingJob in a Location.

airflow.providers.google.cloud.operators.vertex_ai.custom_job.ListCustomTrainingJobOperator
View Docs Source
O

AutoMLTrainingJobBaseOperator

The base class for operators that launch AutoML jobs on VertexAI.

airflow.providers.google.cloud.operators.vertex_ai.auto_ml.AutoMLTrainingJobBaseOperator
View Docs Source
O

CreateAutoMLForecastingTrainingJobOperator

Create AutoML Forecasting Training job.

airflow.providers.google.cloud.operators.vertex_ai.auto_ml.CreateAutoMLForecastingTrainingJobOperator
View Docs Source
O

CreateAutoMLImageTrainingJobOperator

Create Auto ML Image Training job.

airflow.providers.google.cloud.operators.vertex_ai.auto_ml.CreateAutoMLImageTrainingJobOperator
View Docs Source
O

CreateAutoMLTabularTrainingJobOperator

Create Auto ML Tabular Training job.

airflow.providers.google.cloud.operators.vertex_ai.auto_ml.CreateAutoMLTabularTrainingJobOperator
View Docs Source
O

DeleteAutoMLTrainingJobOperator

Delete an AutoML training job.

airflow.providers.google.cloud.operators.vertex_ai.auto_ml.DeleteAutoMLTrainingJobOperator
View Docs Source
O

ListAutoMLTrainingJobOperator

List an AutoML training job.

airflow.providers.google.cloud.operators.vertex_ai.auto_ml.ListAutoMLTrainingJobOperator
View Docs Source
O

CreateBatchPredictionJobOperator Deferrable

Creates a BatchPredictionJob. A BatchPredictionJob once created will right away be attempted to start.

airflow.providers.google.cloud.operators.vertex_ai.batch_prediction_job.CreateBatchPredictionJobOperator
View Docs Source
O

DeleteBatchPredictionJobOperator

Deletes a BatchPredictionJob. Can only be called on jobs that already finished.

airflow.providers.google.cloud.operators.vertex_ai.batch_prediction_job.DeleteBatchPredictionJobOperator
View Docs Source
O

GetBatchPredictionJobOperator

Gets a BatchPredictionJob.

airflow.providers.google.cloud.operators.vertex_ai.batch_prediction_job.GetBatchPredictionJobOperator
View Docs Source
O

ListBatchPredictionJobsOperator

Lists BatchPredictionJobs in a Location.

airflow.providers.google.cloud.operators.vertex_ai.batch_prediction_job.ListBatchPredictionJobsOperator
View Docs Source
O

CreateEndpointOperator

Creates an Endpoint.

airflow.providers.google.cloud.operators.vertex_ai.endpoint_service.CreateEndpointOperator
View Docs Source
O

DeleteEndpointOperator

Deletes an Endpoint.

airflow.providers.google.cloud.operators.vertex_ai.endpoint_service.DeleteEndpointOperator
View Docs Source
O

DeployModelOperator

Deploys a Model into this Endpoint, creating a DeployedModel within it.

airflow.providers.google.cloud.operators.vertex_ai.endpoint_service.DeployModelOperator
View Docs Source
O

GetEndpointOperator

Gets an Endpoint.

airflow.providers.google.cloud.operators.vertex_ai.endpoint_service.GetEndpointOperator
View Docs Source
O

ListEndpointsOperator

Lists Endpoints in a Location.

airflow.providers.google.cloud.operators.vertex_ai.endpoint_service.ListEndpointsOperator
View Docs Source
O

UndeployModelOperator

Undeploys a Model from an Endpoint, removing a DeployedModel from it, and freeing all used resources.

airflow.providers.google.cloud.operators.vertex_ai.endpoint_service.UndeployModelOperator
View Docs Source
O

UpdateEndpointOperator

Updates an Endpoint.

airflow.providers.google.cloud.operators.vertex_ai.endpoint_service.UpdateEndpointOperator
View Docs Source
O

CreateExperimentOperator

Use the Vertex AI SDK to create experiment.

airflow.providers.google.cloud.operators.vertex_ai.experiment_service.CreateExperimentOperator
View Docs Source
O

CreateExperimentRunOperator

Use the Vertex AI SDK to create experiment run.

airflow.providers.google.cloud.operators.vertex_ai.experiment_service.CreateExperimentRunOperator
View Docs Source
O

DeleteExperimentOperator

Use the Vertex AI SDK to delete experiment.

airflow.providers.google.cloud.operators.vertex_ai.experiment_service.DeleteExperimentOperator
View Docs Source
O

DeleteExperimentRunOperator

Use the Vertex AI SDK to delete experiment run.

airflow.providers.google.cloud.operators.vertex_ai.experiment_service.DeleteExperimentRunOperator
View Docs Source
O

ListExperimentRunsOperator

Use the Vertex AI SDK to list experiment runs in experiment.

airflow.providers.google.cloud.operators.vertex_ai.experiment_service.ListExperimentRunsOperator
View Docs Source
O

UpdateExperimentRunStateOperator

Use the Vertex AI SDK to update state of the experiment run.

airflow.providers.google.cloud.operators.vertex_ai.experiment_service.UpdateExperimentRunStateOperator
View Docs Source
O

CreateHyperparameterTuningJobOperator Deferrable

Create Hyperparameter Tuning job.

airflow.providers.google.cloud.operators.vertex_ai.hyperparameter_tuning_job.CreateHyperparameterTuningJobOperator
View Docs Source
O

DeleteHyperparameterTuningJobOperator

Deletes a HyperparameterTuningJob.

airflow.providers.google.cloud.operators.vertex_ai.hyperparameter_tuning_job.DeleteHyperparameterTuningJobOperator
View Docs Source
O

GetHyperparameterTuningJobOperator

Gets a HyperparameterTuningJob.

airflow.providers.google.cloud.operators.vertex_ai.hyperparameter_tuning_job.GetHyperparameterTuningJobOperator
View Docs Source
O

ListHyperparameterTuningJobOperator

Lists HyperparameterTuningJobs in a Location.

airflow.providers.google.cloud.operators.vertex_ai.hyperparameter_tuning_job.ListHyperparameterTuningJobOperator
View Docs Source
O

AddVersionAliasesOnModelOperator

Adds version aliases for the Model.

airflow.providers.google.cloud.operators.vertex_ai.model_service.AddVersionAliasesOnModelOperator
View Docs Source
O

DeleteModelOperator

Deletes a Model.

airflow.providers.google.cloud.operators.vertex_ai.model_service.DeleteModelOperator
View Docs Source
O

DeleteModelVersionOperator

Delete Model version in a Location.

airflow.providers.google.cloud.operators.vertex_ai.model_service.DeleteModelVersionOperator
View Docs Source
O

DeleteVersionAliasesOnModelOperator

Deletes version aliases for the Model.

airflow.providers.google.cloud.operators.vertex_ai.model_service.DeleteVersionAliasesOnModelOperator
View Docs Source
O

ExportModelOperator

Exports a trained, exportable Model to a location specified by the user.

airflow.providers.google.cloud.operators.vertex_ai.model_service.ExportModelOperator
View Docs Source
O

GetModelOperator

Retrieves a Model.

airflow.providers.google.cloud.operators.vertex_ai.model_service.GetModelOperator
View Docs Source
O

ListModelVersionsOperator

Lists Model versions in a Location.

airflow.providers.google.cloud.operators.vertex_ai.model_service.ListModelVersionsOperator
View Docs Source
O

ListModelsOperator

Lists Models in a Location.

airflow.providers.google.cloud.operators.vertex_ai.model_service.ListModelsOperator
View Docs Source
O

SetDefaultVersionOnModelOperator

Sets the desired Model version as Default.

airflow.providers.google.cloud.operators.vertex_ai.model_service.SetDefaultVersionOnModelOperator
View Docs Source
O

UploadModelOperator

Uploads a Model artifact into Vertex AI.

airflow.providers.google.cloud.operators.vertex_ai.model_service.UploadModelOperator
View Docs Source
O

DeletePipelineJobOperator

Delete a Pipeline job.

airflow.providers.google.cloud.operators.vertex_ai.pipeline_job.DeletePipelineJobOperator
View Docs Source
O

GetPipelineJobOperator

Get a Pipeline job.

airflow.providers.google.cloud.operators.vertex_ai.pipeline_job.GetPipelineJobOperator
View Docs Source
O

ListPipelineJobOperator

Lists PipelineJob in a Location.

airflow.providers.google.cloud.operators.vertex_ai.pipeline_job.ListPipelineJobOperator
View Docs Source
O

RunPipelineJobOperator Deferrable

Create and run a Pipeline job.

airflow.providers.google.cloud.operators.vertex_ai.pipeline_job.RunPipelineJobOperator
View Docs Source
O

RunEvaluationOperator

Use the Rapid Evaluation API to evaluate a model.

airflow.providers.google.cloud.operators.vertex_ai.generative_model.RunEvaluationOperator
View Docs Source
O

CreateFeatureOnlineStoreOperator

Create the Feature Online store.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.CreateFeatureOnlineStoreOperator
View Docs Source
O

CreateFeatureViewOperator

Create request for Feature View creation.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.CreateFeatureViewOperator
View Docs Source
O

DeleteFeatureOnlineStoreOperator

Delete the Feature Online store.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.DeleteFeatureOnlineStoreOperator
View Docs Source
O

DeleteFeatureViewOperator

Delete the Feature View.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.DeleteFeatureViewOperator
View Docs Source
O

FetchFeatureValuesOperator

Fetch features data from the Feature View provided.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.FetchFeatureValuesOperator
View Docs Source
O

GetFeatureOnlineStoreOperator

Get Feature Online store instance.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.GetFeatureOnlineStoreOperator
View Docs Source
O

GetFeatureViewSyncOperator

Retrieve the status and details of a Feature View synchronization operation.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.GetFeatureViewSyncOperator
View Docs Source
O

SyncFeatureViewOperator

Initiate a synchronization operation for a Feature View in Vertex AI Feature Store.

airflow.providers.google.cloud.operators.vertex_ai.feature_store.SyncFeatureViewOperator
View Docs Source
O

CreateRayClusterOperator

Create a Ray cluster on the Vertex AI.

airflow.providers.google.cloud.operators.vertex_ai.ray.CreateRayClusterOperator
View Docs Source
O

DeleteRayClusterOperator

Delete Ray cluster.

airflow.providers.google.cloud.operators.vertex_ai.ray.DeleteRayClusterOperator
View Docs Source
O

GetRayClusterOperator

Get Ray cluster.

airflow.providers.google.cloud.operators.vertex_ai.ray.GetRayClusterOperator
View Docs Source
O

ListRayClustersOperator

List Ray clusters under the currently authenticated project.

airflow.providers.google.cloud.operators.vertex_ai.ray.ListRayClustersOperator
View Docs Source
O

RayBaseOperator

Base class for Ray operators.

airflow.providers.google.cloud.operators.vertex_ai.ray.RayBaseOperator
View Docs Source
O

UpdateRayClusterOperator

Update Ray cluster (currently support resizing node counts for worker nodes).

airflow.providers.google.cloud.operators.vertex_ai.ray.UpdateRayClusterOperator
View Docs Source
O

CreateAgentEngineOperator

Create a Vertex AI Agent Engine.

airflow.providers.google.cloud.operators.vertex_ai.agent_engine.CreateAgentEngineOperator
View Docs Source
O

DeleteAgentEngineOperator

Delete a Vertex AI Agent Engine.

airflow.providers.google.cloud.operators.vertex_ai.agent_engine.DeleteAgentEngineOperator
View Docs Source
O

GetAgentEngineOperator

Get a Vertex AI Agent Engine.

airflow.providers.google.cloud.operators.vertex_ai.agent_engine.GetAgentEngineOperator
View Docs Source
O

RunQueryJobOperator Deferrable

Run a query job on a Vertex AI Agent Engine.

airflow.providers.google.cloud.operators.vertex_ai.agent_engine.RunQueryJobOperator
View Docs Source
O

RunReasoningEngineQueryOperator

Query a Vertex AI Reasoning Engine synchronously.

airflow.providers.google.cloud.operators.vertex_ai.agent_engine.RunReasoningEngineQueryOperator
View Docs Source
O

UpdateAgentEngineOperator

Update a Vertex AI Agent Engine.

airflow.providers.google.cloud.operators.vertex_ai.agent_engine.UpdateAgentEngineOperator
View Docs Source
O

DataStudioStartPdtBuildOperator

Submits a PDT materialization job to Looker.

airflow.providers.google.cloud.operators.looker.DataStudioStartPdtBuildOperator
View Docs Source
O

LookerStartPdtBuildOperator

Submits a PDT materialization job to Looker.

airflow.providers.google.cloud.operators.looker.LookerStartPdtBuildOperator
View Docs Source
O

DataformCancelWorkflowInvocationOperator

Requests cancellation of a running WorkflowInvocation.

airflow.providers.google.cloud.operators.dataform.DataformCancelWorkflowInvocationOperator
View Docs Source
O

DataformCreateCompilationResultOperator

Creates a new CompilationResult in a given project and location.

airflow.providers.google.cloud.operators.dataform.DataformCreateCompilationResultOperator
View Docs Source
O

DataformCreateRepositoryOperator

Creates repository.

airflow.providers.google.cloud.operators.dataform.DataformCreateRepositoryOperator
View Docs Source
O

DataformCreateWorkflowInvocationOperator

Creates a new WorkflowInvocation in a given Repository.

airflow.providers.google.cloud.operators.dataform.DataformCreateWorkflowInvocationOperator
View Docs Source
O

DataformCreateWorkspaceOperator

Creates workspace.

airflow.providers.google.cloud.operators.dataform.DataformCreateWorkspaceOperator
View Docs Source
O

DataformDeleteRepositoryOperator

Deletes repository.

airflow.providers.google.cloud.operators.dataform.DataformDeleteRepositoryOperator
View Docs Source
O

DataformDeleteWorkspaceOperator

Deletes workspace.

airflow.providers.google.cloud.operators.dataform.DataformDeleteWorkspaceOperator
View Docs Source
O

DataformGetCompilationResultOperator

Fetches a single CompilationResult.

airflow.providers.google.cloud.operators.dataform.DataformGetCompilationResultOperator
View Docs Source
O

DataformGetWorkflowInvocationOperator

Fetches a single WorkflowInvocation.

airflow.providers.google.cloud.operators.dataform.DataformGetWorkflowInvocationOperator
View Docs Source
O

DataformInstallNpmPackagesOperator

Install NPM dependencies in the provided workspace.

airflow.providers.google.cloud.operators.dataform.DataformInstallNpmPackagesOperator
View Docs Source
O

DataformMakeDirectoryOperator

Makes new directory in specified workspace.

airflow.providers.google.cloud.operators.dataform.DataformMakeDirectoryOperator
View Docs Source
O

DataformQueryWorkflowInvocationActionsOperator

Returns WorkflowInvocationActions in a given WorkflowInvocation.

airflow.providers.google.cloud.operators.dataform.DataformQueryWorkflowInvocationActionsOperator
View Docs Source
O

DataformRemoveDirectoryOperator

Removes directory in specified workspace.

airflow.providers.google.cloud.operators.dataform.DataformRemoveDirectoryOperator
View Docs Source
O

DataformRemoveFileOperator

Removes file in specified workspace.

airflow.providers.google.cloud.operators.dataform.DataformRemoveFileOperator
View Docs Source
O

DataformWriteFileOperator

Writes new file to specified workspace.

airflow.providers.google.cloud.operators.dataform.DataformWriteFileOperator
View Docs Source
O

CloudBatchDeleteJobOperator

Deletes a job and wait for the operation to be completed.

airflow.providers.google.cloud.operators.cloud_batch.CloudBatchDeleteJobOperator
View Docs Source
O

CloudBatchListJobsOperator

List Cloud Batch jobs.

airflow.providers.google.cloud.operators.cloud_batch.CloudBatchListJobsOperator
View Docs Source
O

CloudBatchListTasksOperator

List Cloud Batch tasks for a given job.

airflow.providers.google.cloud.operators.cloud_batch.CloudBatchListTasksOperator
View Docs Source
O

CloudBatchSubmitJobOperator Deferrable

Submit a job and wait for its completion.

airflow.providers.google.cloud.operators.cloud_batch.CloudBatchSubmitJobOperator
View Docs Source
O

ManagedKafkaBaseOperator

Base class for Managed Kafka operators.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaBaseOperator
View Docs Source
O

ManagedKafkaCreateClusterOperator

Create a new Apache Kafka cluster.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaCreateClusterOperator
View Docs Source
O

ManagedKafkaCreateTopicOperator

Create a new topic in a given project and location.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaCreateTopicOperator
View Docs Source
O

ManagedKafkaDeleteClusterOperator

Delete an Apache Kafka cluster.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaDeleteClusterOperator
View Docs Source
O

ManagedKafkaDeleteConsumerGroupOperator

Delete a single consumer group.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaDeleteConsumerGroupOperator
View Docs Source
O

ManagedKafkaDeleteTopicOperator

Delete a single topic.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaDeleteTopicOperator
View Docs Source
O

ManagedKafkaGetClusterOperator

Get an Apache Kafka cluster.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaGetClusterOperator
View Docs Source
O

ManagedKafkaGetConsumerGroupOperator

Return the properties of a single consumer group.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaGetConsumerGroupOperator
View Docs Source
O

ManagedKafkaGetTopicOperator

Return the properties of a single topic.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaGetTopicOperator
View Docs Source
O

ManagedKafkaListClustersOperator

List the clusters in a given project and location.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaListClustersOperator
View Docs Source
O

ManagedKafkaListConsumerGroupsOperator

List the consumer groups in a given cluster.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaListConsumerGroupsOperator
View Docs Source
O

ManagedKafkaListTopicsOperator

List the topics in a given cluster.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaListTopicsOperator
View Docs Source
O

ManagedKafkaUpdateClusterOperator

Update the properties of a single cluster.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaUpdateClusterOperator
View Docs Source
O

ManagedKafkaUpdateConsumerGroupOperator

Update the properties of a single consumer group.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaUpdateConsumerGroupOperator
View Docs Source
O

ManagedKafkaUpdateTopicOperator

Update the properties of a single topic.

airflow.providers.google.cloud.operators.managed_kafka.ManagedKafkaUpdateTopicOperator
View Docs Source
O

CloudLoggingCreateSinkOperator

Creates a Cloud Logging export sink in a GCP project.

airflow.providers.google.cloud.operators.cloud_logging_sink.CloudLoggingCreateSinkOperator
View Docs Source
O

CloudLoggingDeleteSinkOperator

Deletes a Cloud Logging export sink from a GCP project.

airflow.providers.google.cloud.operators.cloud_logging_sink.CloudLoggingDeleteSinkOperator
View Docs Source
O

CloudLoggingListSinksOperator

Lists Cloud Logging export sinks in a Google Cloud project.

airflow.providers.google.cloud.operators.cloud_logging_sink.CloudLoggingListSinksOperator
View Docs Source
O

CloudLoggingUpdateSinkOperator

Updates an existing Cloud Logging export sink.

airflow.providers.google.cloud.operators.cloud_logging_sink.CloudLoggingUpdateSinkOperator
View Docs Source
O

GenAICountTokensOperator

Use Count Tokens API to calculate the number of input tokens before sending a request to Gemini API.

airflow.providers.google.cloud.operators.gen_ai.GenAICountTokensOperator
View Docs Source
O

GenAICreateCachedContentOperator

Create CachedContent resource to reduce the cost of requests that contain repeat content with high input token counts.

airflow.providers.google.cloud.operators.gen_ai.GenAICreateCachedContentOperator
View Docs Source
O

GenAIGeminiCancelBatchJobOperator

Cancel Batch job using Gemini API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiCancelBatchJobOperator
View Docs Source
O

GenAIGeminiCreateBatchJobOperator Deferrable

Create Batch job using Gemini Batch API. Use to generate model response for several requests.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiCreateBatchJobOperator
View Docs Source
O

GenAIGeminiCreateEmbeddingsBatchJobOperator Deferrable

Create embeddings Batch job using Gemini Batch API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiCreateEmbeddingsBatchJobOperator
View Docs Source
O

GenAIGeminiDeleteBatchJobOperator

Queue a batch job for deletion using the Gemini API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiDeleteBatchJobOperator
View Docs Source
O

GenAIGeminiDeleteFileOperator

Delete file uploaded to Gemini Files API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiDeleteFileOperator
View Docs Source
O

GenAIGeminiGetBatchJobOperator

Get Batch job using Gemini API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiGetBatchJobOperator
View Docs Source
O

GenAIGeminiGetFileOperator

Get file's metadata uploaded to Gemini Files API by using GenAIGeminiUploadFileOperator.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiGetFileOperator
View Docs Source
O

GenAIGeminiListBatchJobsOperator

Get list of Batch jobs metadata using Gemini API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiListBatchJobsOperator
View Docs Source
O

GenAIGeminiListFilesOperator

List files uploaded to Gemini Files API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiListFilesOperator
View Docs Source
O

GenAIGeminiUploadFileOperator

Upload file to Gemini Files API.

airflow.providers.google.cloud.operators.gen_ai.GenAIGeminiUploadFileOperator
View Docs Source
O

GenAIGenerateContentOperator

Generate a model response based on given configuration. Input capabilities differ between models, including tuned models.

airflow.providers.google.cloud.operators.gen_ai.GenAIGenerateContentOperator
View Docs Source
O

GenAIGenerateEmbeddingsOperator

Uses the Gemini AI Embeddings API to generate embeddings for words, phrases, sentences, and code.

airflow.providers.google.cloud.operators.gen_ai.GenAIGenerateEmbeddingsOperator
View Docs Source
O

GenAISupervisedFineTuningTrainOperator

Create a tuning job to adapt model behavior with a labeled dataset.

airflow.providers.google.cloud.operators.gen_ai.GenAISupervisedFineTuningTrainOperator
View Docs Source
O

RayDeleteJobOperator

Delete Job on Ray cluster in a terminal state and all of its associated data.

airflow.providers.google.cloud.operators.ray.RayDeleteJobOperator
View Docs Source
O

RayGetJobInfoOperator

Get the latest status and other information associated with a Job on Ray cluster.

airflow.providers.google.cloud.operators.ray.RayGetJobInfoOperator
View Docs Source
O

RayJobBaseOperator

Base class for Jobs on Ray operators.

airflow.providers.google.cloud.operators.ray.RayJobBaseOperator
View Docs Source
O

RayListJobsOperator

List all jobs along with their status and other information.

airflow.providers.google.cloud.operators.ray.RayListJobsOperator
View Docs Source
O

RayStopJobOperator

Stop Job on Ray cluster.

airflow.providers.google.cloud.operators.ray.RayStopJobOperator
View Docs Source
O

RaySubmitJobOperator

Submit and execute Job on Ray cluster.

airflow.providers.google.cloud.operators.ray.RaySubmitJobOperator
View Docs Source
O

GoogleBidManagerCreateQueryOperator

Creates a query.

airflow.providers.google.marketing_platform.operators.bid_manager.GoogleBidManagerCreateQueryOperator
View Docs Source
O

GoogleBidManagerDeleteQueryOperator

Deletes a stored query as well as the associated stored reports.

airflow.providers.google.marketing_platform.operators.bid_manager.GoogleBidManagerDeleteQueryOperator
View Docs Source
O

GoogleBidManagerDownloadReportOperator

Retrieves a stored query.

airflow.providers.google.marketing_platform.operators.bid_manager.GoogleBidManagerDownloadReportOperator
View Docs Source
O

GoogleBidManagerRunQueryOperator

Runs a stored query to generate a report.

airflow.providers.google.marketing_platform.operators.bid_manager.GoogleBidManagerRunQueryOperator
View Docs Source
H

BigQueryAsyncHook

Uses gcloud-aio library to retrieve Job details.

airflow.providers.google.cloud.hooks.bigquery.BigQueryAsyncHook
View Docs Source
H

BigQueryHook

Interact with BigQuery.

airflow.providers.google.cloud.hooks.bigquery.BigQueryHook
View Docs Source
H

BigQueryTableAsyncHook

Async hook for BigQuery Table.

airflow.providers.google.cloud.hooks.bigquery.BigQueryTableAsyncHook
View Docs Source
H

AsyncBiqQueryDataTransferServiceHook

Hook of the BigQuery service to be used with async client of the Google library.

airflow.providers.google.cloud.hooks.bigquery_dts.AsyncBiqQueryDataTransferServiceHook
View Docs Source
H

BiqQueryDataTransferServiceHook

Hook for Google Bigquery Transfer API.

airflow.providers.google.cloud.hooks.bigquery_dts.BiqQueryDataTransferServiceHook
View Docs Source
H

BigtableHook

Hook for Google Cloud Bigtable APIs.

airflow.providers.google.cloud.hooks.bigtable.BigtableHook
View Docs Source
H

AlloyDbHook

Google Alloy DB Hook.

airflow.providers.google.cloud.hooks.alloy_db.AlloyDbHook
View Docs Source
H

CloudBuildAsyncHook

Asynchronous Hook for the Google Cloud Build Service.

airflow.providers.google.cloud.hooks.cloud_build.CloudBuildAsyncHook
View Docs Source
H

CloudBuildHook

Hook for the Google Cloud Build Service.

airflow.providers.google.cloud.hooks.cloud_build.CloudBuildHook
View Docs Source
H

CloudComposerAsyncHook

Hook for Google Cloud Composer async APIs.

airflow.providers.google.cloud.hooks.cloud_composer.CloudComposerAsyncHook
View Docs Source
H

CloudComposerHook

Hook for Google Cloud Composer APIs.

airflow.providers.google.cloud.hooks.cloud_composer.CloudComposerHook
View Docs Source
H

CloudRunAsyncHook

Async hook for the Google Cloud Run service.

airflow.providers.google.cloud.hooks.cloud_run.CloudRunAsyncHook
View Docs Source
H

CloudRunHook

Hook for the Google Cloud Run service.

airflow.providers.google.cloud.hooks.cloud_run.CloudRunHook
View Docs Source
H

CloudRunServiceAsyncHook

Async hook for the Google Cloud Run services.

airflow.providers.google.cloud.hooks.cloud_run.CloudRunServiceAsyncHook
View Docs Source
H

CloudRunServiceHook

Hook for the Google Cloud Run services.

airflow.providers.google.cloud.hooks.cloud_run.CloudRunServiceHook
View Docs Source
H

CloudMemorystoreHook

Hook for Google Cloud Memorystore APIs.

airflow.providers.google.cloud.hooks.cloud_memorystore.CloudMemorystoreHook
View Docs Source
H

CloudMemorystoreMemcachedHook

Hook for Google Cloud Memorystore for Memcached service APIs.

airflow.providers.google.cloud.hooks.cloud_memorystore.CloudMemorystoreMemcachedHook
View Docs Source
H

CloudSQLAsyncHook

Class to get asynchronous hook for Google Cloud SQL.

airflow.providers.google.cloud.hooks.cloud_sql.CloudSQLAsyncHook
View Docs Source
H

CloudSQLDatabaseHook

Serves DB connection configuration for Google Cloud SQL (Connections of *gcpcloudsqldb://* type).

airflow.providers.google.cloud.hooks.cloud_sql.CloudSQLDatabaseHook
View Docs Source
H

CloudSQLHook

Hook for Google Cloud SQL APIs.

airflow.providers.google.cloud.hooks.cloud_sql.CloudSQLHook
View Docs Source
H

CloudDataTransferServiceAsyncHook

Asynchronous hook for Google Storage Transfer Service.

airflow.providers.google.cloud.hooks.cloud_storage_transfer_service.CloudDataTransferServiceAsyncHook
View Docs Source
H

CloudDataTransferServiceHook

Google Storage Transfer Service functionalities.

airflow.providers.google.cloud.hooks.cloud_storage_transfer_service.CloudDataTransferServiceHook
View Docs Source
H

ComputeEngineHook

Hook for Google Compute Engine APIs.

airflow.providers.google.cloud.hooks.compute.ComputeEngineHook
View Docs Source
H

ComputeEngineSSHHook

Hook to connect to a remote instance in compute engine.

airflow.providers.google.cloud.hooks.compute_ssh.ComputeEngineSSHHook
View Docs Source
H

AsyncDataflowHook

Async hook class for dataflow service.

airflow.providers.google.cloud.hooks.dataflow.AsyncDataflowHook
View Docs Source
H

DataflowHook

Hook for Google Dataflow.

airflow.providers.google.cloud.hooks.dataflow.DataflowHook
View Docs Source
H

DataFusionAsyncHook

Class to get asynchronous hook for DataFusion.

airflow.providers.google.cloud.hooks.datafusion.DataFusionAsyncHook
View Docs Source
H

DataFusionHook

Hook for Google DataFusion.

airflow.providers.google.cloud.hooks.datafusion.DataFusionHook
View Docs Source
H

DataplexAsyncHook

Asynchronous Hook for Google Cloud Dataplex APIs.

airflow.providers.google.cloud.hooks.dataplex.DataplexAsyncHook
View Docs Source
H

DataplexHook

Hook for Google Dataplex.

airflow.providers.google.cloud.hooks.dataplex.DataplexHook
View Docs Source
H

GoogleDataprepHook

Hook for connection with Dataprep API.

airflow.providers.google.cloud.hooks.dataprep.GoogleDataprepHook
View Docs Source
H

DataprocMetastoreHook

Hook for Google Cloud Dataproc Metastore APIs.

airflow.providers.google.cloud.hooks.dataproc_metastore.DataprocMetastoreHook
View Docs Source
H

DataprocAsyncHook

Asynchronous interaction with Google Cloud Dataproc APIs.

airflow.providers.google.cloud.hooks.dataproc.DataprocAsyncHook
View Docs Source
H

DataprocHook

Google Cloud Dataproc APIs.

airflow.providers.google.cloud.hooks.dataproc.DataprocHook
View Docs Source
H

DatastoreHook

Interact with Google Cloud Datastore. This hook uses the Google Cloud connection.

airflow.providers.google.cloud.hooks.datastore.DatastoreHook
View Docs Source
H

CloudDLPHook

Hook for Google Cloud Data Loss Prevention (DLP) APIs.

airflow.providers.google.cloud.hooks.dlp.CloudDLPHook
View Docs Source
H

CloudFunctionsHook

Google Cloud Functions APIs.

airflow.providers.google.cloud.hooks.functions.CloudFunctionsHook
View Docs Source
H

GCSAsyncHook

GCSAsyncHook run on the trigger worker, inherits from GoogleBaseAsyncHook.

airflow.providers.google.cloud.hooks.gcs.GCSAsyncHook
View Docs Source
H

GCSHook

Use the Google Cloud connection to interact with Google Cloud Storage.

airflow.providers.google.cloud.hooks.gcs.GCSHook
View Docs Source
H

GoogleDeploymentManagerHook

Interact with Google Cloud Deployment Manager using the Google Cloud connection.

airflow.providers.google.cloud.hooks.gdm.GoogleDeploymentManagerHook
View Docs Source
H

CloudKMSHook

Hook for Google Cloud Key Management service.

airflow.providers.google.cloud.hooks.kms.CloudKMSHook
View Docs Source
H

GKEAsyncHook

Asynchronous client of GKE.

airflow.providers.google.cloud.hooks.kubernetes_engine.GKEAsyncHook
View Docs Source
H

GKEHook

Google Kubernetes Engine cluster APIs.

airflow.providers.google.cloud.hooks.kubernetes_engine.GKEHook
View Docs Source
H

GKEKubernetesAsyncHook

Async GKE authenticated hook for standard Kubernetes API.

airflow.providers.google.cloud.hooks.kubernetes_engine.GKEKubernetesAsyncHook
View Docs Source
H

GKEKubernetesHook

GKE authenticated hook for standard Kubernetes API.

airflow.providers.google.cloud.hooks.kubernetes_engine.GKEKubernetesHook
View Docs Source
H

CloudNaturalLanguageHook

Hook for Google Cloud Natural Language Service.

airflow.providers.google.cloud.hooks.natural_language.CloudNaturalLanguageHook
View Docs Source
H

OSLoginHook

Hook for Google OS login APIs.

airflow.providers.google.cloud.hooks.os_login.OSLoginHook
View Docs Source
H

PubSubAsyncHook

Class to get asynchronous hook for Google Cloud PubSub.

airflow.providers.google.cloud.hooks.pubsub.PubSubAsyncHook
View Docs Source
H

PubSubHook

Hook for accessing Google Pub/Sub.

airflow.providers.google.cloud.hooks.pubsub.PubSubHook
View Docs Source
H

GoogleCloudSecretManagerHook

Hook for the Google Cloud Secret Manager API.

airflow.providers.google.cloud.hooks.secret_manager.GoogleCloudSecretManagerHook
View Docs Source
H

SpannerHook

Hook for Google Cloud Spanner APIs.

airflow.providers.google.cloud.hooks.spanner.SpannerHook
View Docs Source
H

CloudSpeechToTextHook

Hook for Google Cloud Speech API.

airflow.providers.google.cloud.hooks.speech_to_text.CloudSpeechToTextHook
View Docs Source
H

CloudMonitoringHook

Cloud Monitoring Hook for connecting with Google Cloud Monitoring.

airflow.providers.google.cloud.hooks.cloud_monitoring.CloudMonitoringHook
View Docs Source
H

CloudTasksHook

Hook for Google Cloud Tasks APIs.

airflow.providers.google.cloud.hooks.tasks.CloudTasksHook
View Docs Source
H

CloudTextToSpeechHook

Hook for Google Cloud Text to Speech API.

airflow.providers.google.cloud.hooks.text_to_speech.CloudTextToSpeechHook
View Docs Source
H

CloudTranslateHook

Hook for Google Cloud translate APIs.

airflow.providers.google.cloud.hooks.translate.CloudTranslateHook
View Docs Source
H

TranslateHook

Hook for Google Cloud translation (Advanced) using client version V3.

airflow.providers.google.cloud.hooks.translate.TranslateHook
View Docs Source
H

CloudVideoIntelligenceHook

Hook for Google Cloud Video Intelligence APIs.

airflow.providers.google.cloud.hooks.video_intelligence.CloudVideoIntelligenceHook
View Docs Source
H

CloudVisionHook

Hook for Google Cloud Vision APIs.

airflow.providers.google.cloud.hooks.vision.CloudVisionHook
View Docs Source
H

WorkflowsHook

Hook for Google GCP APIs.

airflow.providers.google.cloud.hooks.workflows.WorkflowsHook
View Docs Source
H

GoogleBaseAsyncHook

GoogleBaseAsyncHook inherits from BaseHook class, run on the trigger worker.

airflow.providers.google.common.hooks.base_google.GoogleBaseAsyncHook
View Docs Source
H

GoogleBaseHook

A base hook for Google cloud-related hooks.

airflow.providers.google.common.hooks.base_google.GoogleBaseHook
View Docs Source
H

GoogleDiscoveryApiHook

A hook to use the Google API Discovery Service.

airflow.providers.google.common.hooks.discovery_api.GoogleDiscoveryApiHook
View Docs Source
H

CloudFirestoreHook

Hook for the Google Firestore APIs.

airflow.providers.google.firebase.hooks.firestore.CloudFirestoreHook
View Docs Source
H

GoogleAnalyticsAdminHook

Hook for Google Analytics 4 (GA4) Admin API.

airflow.providers.google.marketing_platform.hooks.analytics_admin.GoogleAnalyticsAdminHook
View Docs Source
H

GoogleCampaignManagerHook

Hook for Google Campaign Manager.

airflow.providers.google.marketing_platform.hooks.campaign_manager.GoogleCampaignManagerHook
View Docs Source
H

GoogleDisplayVideo360Hook

Hook for Google Display & Video 360.

airflow.providers.google.marketing_platform.hooks.display_video.GoogleDisplayVideo360Hook
View Docs Source
H

GoogleSearchAdsHook

Hook for Google Search Ads 360.

airflow.providers.google.marketing_platform.hooks.search_ads.GoogleSearchAdsHook
View Docs Source
H

GoogleSearchAdsReportingHook

Hook for the Google Search Ads 360 Reporting API.

airflow.providers.google.marketing_platform.hooks.search_ads.GoogleSearchAdsReportingHook
View Docs Source
H

GoogleCalendarHook

Interact with Google Calendar via Google Cloud connection.

airflow.providers.google.suite.hooks.calendar.GoogleCalendarHook
View Docs Source
H

GoogleDriveHook

Hook for the Google Drive APIs.

airflow.providers.google.suite.hooks.drive.GoogleDriveHook
View Docs Source
H

GSheetsHook

Interact with Google Sheets via Google Cloud connection.

airflow.providers.google.suite.hooks.sheets.GSheetsHook
View Docs Source
H

LevelDBHook

Plyvel Wrapper to Interact With LevelDB Database.

airflow.providers.google.leveldb.hooks.leveldb.LevelDBHook
View Docs Source
H

DatasetHook

Hook for Google Cloud Vertex AI Dataset APIs.

airflow.providers.google.cloud.hooks.vertex_ai.dataset.DatasetHook
View Docs Source
H

CustomJobAsyncHook

Async hook for Custom Job Service Client.

airflow.providers.google.cloud.hooks.vertex_ai.custom_job.CustomJobAsyncHook
View Docs Source
H

CustomJobHook

Hook for Google Cloud Vertex AI Custom Job APIs.

airflow.providers.google.cloud.hooks.vertex_ai.custom_job.CustomJobHook
View Docs Source
H

AutoMLHook

Hook for Google Cloud Vertex AI Auto ML APIs.

airflow.providers.google.cloud.hooks.vertex_ai.auto_ml.AutoMLHook
View Docs Source
H

BatchPredictionJobAsyncHook

Hook for Google Cloud Vertex AI Batch Prediction Job Async APIs.

airflow.providers.google.cloud.hooks.vertex_ai.batch_prediction_job.BatchPredictionJobAsyncHook
View Docs Source
H

BatchPredictionJobHook

Hook for Google Cloud Vertex AI Batch Prediction Job APIs.

airflow.providers.google.cloud.hooks.vertex_ai.batch_prediction_job.BatchPredictionJobHook
View Docs Source
H

EndpointServiceHook

Hook for Google Cloud Vertex AI Endpoint Service APIs.

airflow.providers.google.cloud.hooks.vertex_ai.endpoint_service.EndpointServiceHook
View Docs Source
H

ExperimentHook

Use the Vertex AI SDK for Python to manage your experiments.

airflow.providers.google.cloud.hooks.vertex_ai.experiment_service.ExperimentHook
View Docs Source
H

ExperimentRunHook

Use the Vertex AI SDK for Python to create and manage your experiment runs.

airflow.providers.google.cloud.hooks.vertex_ai.experiment_service.ExperimentRunHook
View Docs Source
H

HyperparameterTuningJobAsyncHook

Async hook for Google Cloud Vertex AI Hyperparameter Tuning Job APIs.

airflow.providers.google.cloud.hooks.vertex_ai.hyperparameter_tuning_job.HyperparameterTuningJobAsyncHook
View Docs Source
H

HyperparameterTuningJobHook

Hook for Google Cloud Vertex AI Hyperparameter Tuning Job APIs.

airflow.providers.google.cloud.hooks.vertex_ai.hyperparameter_tuning_job.HyperparameterTuningJobHook
View Docs Source
H

ModelServiceHook

Hook for Google Cloud Vertex AI Endpoint Service APIs.

airflow.providers.google.cloud.hooks.vertex_ai.model_service.ModelServiceHook
View Docs Source
H

PipelineJobAsyncHook

Asynchronous hook for Google Cloud Vertex AI Pipeline Job APIs.

airflow.providers.google.cloud.hooks.vertex_ai.pipeline_job.PipelineJobAsyncHook
View Docs Source
H

PipelineJobHook

Hook for Google Cloud Vertex AI Pipeline Job APIs.

airflow.providers.google.cloud.hooks.vertex_ai.pipeline_job.PipelineJobHook
View Docs Source
H

GenerativeModelHook

Hook for Google Cloud Vertex AI Generative Model APIs.

airflow.providers.google.cloud.hooks.vertex_ai.generative_model.GenerativeModelHook
View Docs Source
H

PredictionServiceHook

Hook for Google Cloud Vertex AI Prediction API.

airflow.providers.google.cloud.hooks.vertex_ai.prediction_service.PredictionServiceHook
View Docs Source
H

FeatureStoreHook

Hook for interacting with Google Cloud Vertex AI Feature Store.

airflow.providers.google.cloud.hooks.vertex_ai.feature_store.FeatureStoreHook
View Docs Source
H

AgentEngineAsyncHook

Async hook for Google Cloud Vertex AI Agent Engine APIs.

airflow.providers.google.cloud.hooks.vertex_ai.agent_engine.AgentEngineAsyncHook
View Docs Source
H

AgentEngineHook

Hook for Google Cloud Vertex AI Agent Engine APIs.

airflow.providers.google.cloud.hooks.vertex_ai.agent_engine.AgentEngineHook
View Docs Source
H

RayHook

Hook for Google Cloud Vertex AI Ray APIs.

airflow.providers.google.cloud.hooks.vertex_ai.ray.RayHook
View Docs Source
H

LookerHook

Hook for Looker APIs.

airflow.providers.google.cloud.hooks.looker.LookerHook
View Docs Source
H

DataformHook

Hook for Google Cloud DataForm APIs.

airflow.providers.google.cloud.hooks.dataform.DataformHook
View Docs Source
H

CloudBatchAsyncHook

Async hook for the Google Cloud Batch service.

airflow.providers.google.cloud.hooks.cloud_batch.CloudBatchAsyncHook
View Docs Source
H

CloudBatchHook

Hook for the Google Cloud Batch service.

airflow.providers.google.cloud.hooks.cloud_batch.CloudBatchHook
View Docs Source
H

ManagedKafkaHook

Hook for Managed Service for Apache Kafka APIs.

airflow.providers.google.cloud.hooks.managed_kafka.ManagedKafkaHook
View Docs Source
H

CloudLoggingHook

Hook for Google Cloud Logging Log Sinks API.

airflow.providers.google.cloud.hooks.cloud_logging.CloudLoggingHook
View Docs Source
H

GenAIGeminiAPIAsyncHook

Class for Google Cloud Generative AI Gemini Developer Async API hook.

airflow.providers.google.cloud.hooks.gen_ai.GenAIGeminiAPIAsyncHook
View Docs Source
H

GenAIGeminiAPIHook

Class for Google Cloud Generative AI Gemini Developer API hook.

airflow.providers.google.cloud.hooks.gen_ai.GenAIGeminiAPIHook
View Docs Source
H

GenAIGenerativeModelHook

Class for Google Cloud Generative AI Vertex AI hook.

airflow.providers.google.cloud.hooks.gen_ai.GenAIGenerativeModelHook
View Docs Source
H

RayJobHook

Hook for Jobs APIs.

airflow.providers.google.cloud.hooks.ray.RayJobHook
View Docs Source
H

GoogleBidManagerHook

Hook for Google Bid Manager API.

airflow.providers.google.marketing_platform.hooks.bid_manager.GoogleBidManagerHook
View Docs Source
S

BigQueryRoutineExistenceSensor

Checks for the existence of a routine (UDF, procedure, or TVF) in a BigQuery dataset.

airflow.providers.google.cloud.sensors.bigquery.BigQueryRoutineExistenceSensor
View Docs Source
S

BigQueryStreamingBufferEmptySensor Deferrable

Wait for the streaming buffer of a BigQuery table to be empty.

airflow.providers.google.cloud.sensors.bigquery.BigQueryStreamingBufferEmptySensor
View Docs Source
S

BigQueryTableExistenceSensor Deferrable

Checks for the existence of a table in Google Bigquery.

airflow.providers.google.cloud.sensors.bigquery.BigQueryTableExistenceSensor
View Docs Source
S

BigQueryTablePartitionExistenceSensor Deferrable

Checks for the existence of a partition within a table in Google Bigquery.

airflow.providers.google.cloud.sensors.bigquery.BigQueryTablePartitionExistenceSensor
View Docs Source
S

BigQueryDataTransferServiceTransferRunSensor

Waits for Data Transfer Service run to complete.

airflow.providers.google.cloud.sensors.bigquery_dts.BigQueryDataTransferServiceTransferRunSensor
View Docs Source
S

BigtableTableReplicationCompletedSensor

Sensor that waits for Cloud Bigtable table to be fully replicated to its clusters.

airflow.providers.google.cloud.sensors.bigtable.BigtableTableReplicationCompletedSensor
View Docs Source
S

CloudSQLNoOperationInProgressSensor Deferrable

Wait until a Cloud SQL instance has no administrative operation in progress.

airflow.providers.google.cloud.sensors.cloud_sql.CloudSQLNoOperationInProgressSensor
View Docs Source
S

CloudComposerDAGRunSensor Deferrable

Check if a DAG run has completed.

airflow.providers.google.cloud.sensors.cloud_composer.CloudComposerDAGRunSensor
View Docs Source
S

CloudComposerExternalTaskSensor Deferrable

Waits for a different Dag, task group, or task to complete for a specific composer environment.

airflow.providers.google.cloud.sensors.cloud_composer.CloudComposerExternalTaskSensor
View Docs Source
S

CloudDataTransferServiceJobStatusSensor Deferrable

Waits for at least one operation belonging to the job to have the expected status.

airflow.providers.google.cloud.sensors.cloud_storage_transfer_service.CloudDataTransferServiceJobStatusSensor
View Docs Source
S

DataflowJobAutoScalingEventsSensor Deferrable

Checks for autoscaling events associated with a single job in Google Cloud Dataflow.

airflow.providers.google.cloud.sensors.dataflow.DataflowJobAutoScalingEventsSensor
View Docs Source
S

DataflowJobMessagesSensor Deferrable

Checks for job messages associated with a single job in Google Cloud Dataflow.

airflow.providers.google.cloud.sensors.dataflow.DataflowJobMessagesSensor
View Docs Source
S

DataflowJobMetricsSensor Deferrable

Checks for metrics associated with a single job in Google Cloud Dataflow.

airflow.providers.google.cloud.sensors.dataflow.DataflowJobMetricsSensor
View Docs Source
S

DataflowJobStatusSensor Deferrable

Checks for the status of a job in Google Cloud Dataflow.

airflow.providers.google.cloud.sensors.dataflow.DataflowJobStatusSensor
View Docs Source
S

CloudDataFusionPipelineStateSensor

Check the status of the pipeline in the Google Cloud Data Fusion.

airflow.providers.google.cloud.sensors.datafusion.CloudDataFusionPipelineStateSensor
View Docs Source
S

DataprepJobGroupIsFinishedSensor

Check the status of the Dataprep task to be finished.

airflow.providers.google.cloud.sensors.dataprep.DataprepJobGroupIsFinishedSensor
View Docs Source
S

DataplexDataProfileJobStatusSensor

Check the status of the Dataplex DataProfile job.

airflow.providers.google.cloud.sensors.dataplex.DataplexDataProfileJobStatusSensor
View Docs Source
S

DataplexDataQualityJobStatusSensor

Check the status of the Dataplex DataQuality job.

airflow.providers.google.cloud.sensors.dataplex.DataplexDataQualityJobStatusSensor
View Docs Source
S

DataplexTaskStateSensor

Check the status of the Dataplex task.

airflow.providers.google.cloud.sensors.dataplex.DataplexTaskStateSensor
View Docs Source
S

DataprocBatchSensor

Check for the state of batch.

airflow.providers.google.cloud.sensors.dataproc.DataprocBatchSensor
View Docs Source
S

DataprocJobSensor

Check for the state of a previously submitted Dataproc job.

airflow.providers.google.cloud.sensors.dataproc.DataprocJobSensor
View Docs Source
S

MetastoreHivePartitionSensor

Waits for partitions to show up in Hive.

airflow.providers.google.cloud.sensors.dataproc_metastore.MetastoreHivePartitionSensor
View Docs Source
S

GCSObjectExistenceSensor Deferrable

Checks for the existence of a file in Google Cloud Storage.

airflow.providers.google.cloud.sensors.gcs.GCSObjectExistenceSensor
View Docs Source
S

GCSObjectUpdateSensor Deferrable

Checks if an object is updated in Google Cloud Storage.

airflow.providers.google.cloud.sensors.gcs.GCSObjectUpdateSensor
View Docs Source
S

GCSObjectsWithPrefixExistenceSensor Deferrable

Checks for the existence of GCS objects at a given prefix, passing matches via XCom.

airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor
View Docs Source
S

GCSUploadSessionCompleteSensor Deferrable

Return True if the inactivity period has passed with no increase in the number of objects in the bucket.

airflow.providers.google.cloud.sensors.gcs.GCSUploadSessionCompleteSensor
View Docs Source
S

PubSubPullSensor Deferrable

Pulls messages from a PubSub subscription and passes them through XCom.

airflow.providers.google.cloud.sensors.pubsub.PubSubPullSensor
View Docs Source
S

FeatureViewSyncSensor

Sensor to monitor the state of a Vertex AI Feature View sync operation.

airflow.providers.google.cloud.sensors.vertex_ai.feature_store.FeatureViewSyncSensor
View Docs Source
S

WorkflowExecutionSensor

Checks state of an execution for the given ``workflow_id`` and ``execution_id``.

airflow.providers.google.cloud.sensors.workflows.WorkflowExecutionSensor
View Docs Source
S

GoogleDriveFileExistenceSensor

Checks for the existence of a file in Google Cloud Storage.

airflow.providers.google.suite.sensors.drive.GoogleDriveFileExistenceSensor
View Docs Source
S

GoogleCampaignManagerReportSensor

Check if report is ready.

airflow.providers.google.marketing_platform.sensors.campaign_manager.GoogleCampaignManagerReportSensor
View Docs Source
S

GoogleDisplayVideo360GetSDFDownloadOperationSensor

Sensor for detecting the completion of SDF operation.

airflow.providers.google.marketing_platform.sensors.display_video.GoogleDisplayVideo360GetSDFDownloadOperationSensor
View Docs Source
S

LookerCheckPdtBuildSensor

Check for the state of a previously submitted PDT materialization job.

airflow.providers.google.cloud.sensors.looker.LookerCheckPdtBuildSensor
View Docs Source
S

DataformWorkflowInvocationActionStateSensor

Checks for the status of a Workflow Invocation Action in Google Cloud Dataform.

airflow.providers.google.cloud.sensors.dataform.DataformWorkflowInvocationActionStateSensor
View Docs Source
S

DataformWorkflowInvocationStateSensor

Checks for the status of a Workflow Invocation in Google Cloud Dataform.

airflow.providers.google.cloud.sensors.dataform.DataformWorkflowInvocationStateSensor
View Docs Source
S

TaskQueueEmptySensor

Pulls tasks count from a cloud task queue; waits for queue to return task count as 0.

airflow.providers.google.cloud.sensors.tasks.TaskQueueEmptySensor
View Docs Source
S

GoogleBidManagerRunQuerySensor

Sensor for detecting the completion of DV360 Bid Manager reports for API v2.

airflow.providers.google.marketing_platform.sensors.bid_manager.GoogleBidManagerRunQuerySensor
View Docs Source
T

BigQueryDataTransferRunTrigger

Triggers class to watch the Transfer Run state to define when the job is done.

airflow.providers.google.cloud.triggers.bigquery_dts.BigQueryDataTransferRunTrigger
View Docs Source
T

BigQueryCheckTrigger

BigQueryCheckTrigger run on the trigger worker.

airflow.providers.google.cloud.triggers.bigquery.BigQueryCheckTrigger
View Docs Source
T

BigQueryGetDataTrigger

BigQueryGetDataTrigger run on the trigger worker, inherits from BigQueryInsertJobTrigger class.

airflow.providers.google.cloud.triggers.bigquery.BigQueryGetDataTrigger
View Docs Source
T

BigQueryInsertJobTrigger

BigQueryInsertJobTrigger run on the trigger worker to perform insert operation.

airflow.providers.google.cloud.triggers.bigquery.BigQueryInsertJobTrigger
View Docs Source
T

BigQueryIntervalCheckTrigger

BigQueryIntervalCheckTrigger run on the trigger worker, inherits from BigQueryInsertJobTrigger class.

airflow.providers.google.cloud.triggers.bigquery.BigQueryIntervalCheckTrigger
View Docs Source
T

BigQueryStreamingBufferEmptyTrigger

Poll a BigQuery table until its streaming buffer is empty.

airflow.providers.google.cloud.triggers.bigquery.BigQueryStreamingBufferEmptyTrigger
View Docs Source
T

BigQueryTableExistenceTrigger

Initialize the BigQuery Table Existence Trigger with needed parameters.

airflow.providers.google.cloud.triggers.bigquery.BigQueryTableExistenceTrigger
View Docs Source
T

BigQueryTablePartitionExistenceTrigger

Initialize the BigQuery Table Partition Existence Trigger with needed parameters.

airflow.providers.google.cloud.triggers.bigquery.BigQueryTablePartitionExistenceTrigger
View Docs Source
T

BigQueryValueCheckTrigger

BigQueryValueCheckTrigger run on the trigger worker, inherits from BigQueryInsertJobTrigger class.

airflow.providers.google.cloud.triggers.bigquery.BigQueryValueCheckTrigger
View Docs Source
T

CloudBuildCreateBuildTrigger

CloudBuildCreateBuildTrigger run on the trigger worker to perform create Build operation.

airflow.providers.google.cloud.triggers.cloud_build.CloudBuildCreateBuildTrigger
View Docs Source
T

CloudComposerAirflowCLICommandTrigger

The trigger wait for the Airflow CLI command result.

airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerAirflowCLICommandTrigger
View Docs Source
T

CloudComposerDAGRunTrigger

The trigger wait for the Dag run completion.

airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerDAGRunTrigger
View Docs Source
T

CloudComposerExecutionTrigger

The trigger handles the async communication with the Google Cloud Composer.

airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerExecutionTrigger
View Docs Source
T

CloudComposerExternalTaskTrigger

The trigger wait for the external task completion.

airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerExternalTaskTrigger
View Docs Source
T

CloudRunJobFinishedTrigger

Cloud Run trigger to check if templated job has been finished.

airflow.providers.google.cloud.triggers.cloud_run.CloudRunJobFinishedTrigger
View Docs Source
T

CloudDataTransferServiceRunJobTrigger

CloudDataTransferServiceRunJobTrigger run on the trigger worker to run Cloud Storage Transfer job.

airflow.providers.google.cloud.triggers.cloud_storage_transfer_service.CloudDataTransferServiceRunJobTrigger
View Docs Source
T

CloudStorageTransferServiceCheckJobStatusTrigger

CloudStorageTransferServiceCheckJobStatusTrigger run on the trigger worker to check Cloud Storage Transfer job.

airflow.providers.google.cloud.triggers.cloud_storage_transfer_service.CloudStorageTransferServiceCheckJobStatusTrigger
View Docs Source
T

CloudStorageTransferServiceCreateJobsTrigger

StorageTransferJobTrigger run on the trigger worker to perform Cloud Storage Transfer job.

airflow.providers.google.cloud.triggers.cloud_storage_transfer_service.CloudStorageTransferServiceCreateJobsTrigger
View Docs Source
T

CloudSQLExportTrigger

Trigger that periodically polls information from Cloud SQL API to verify job status.

airflow.providers.google.cloud.triggers.cloud_sql.CloudSQLExportTrigger
View Docs Source
T

CloudSQLNoOperationInProgressTrigger

Trigger that waits until a Cloud SQL instance has no administrative operation in progress.

airflow.providers.google.cloud.triggers.cloud_sql.CloudSQLNoOperationInProgressTrigger
View Docs Source
T

DataflowJobAutoScalingEventTrigger

Trigger that checks for autoscaling events associated with a Dataflow job.

airflow.providers.google.cloud.triggers.dataflow.DataflowJobAutoScalingEventTrigger
View Docs Source
T

DataflowJobMessagesTrigger

Trigger that checks for job messages associated with a Dataflow job.

airflow.providers.google.cloud.triggers.dataflow.DataflowJobMessagesTrigger
View Docs Source
T

DataflowJobMetricsTrigger

Trigger that checks for metrics associated with a Dataflow job.

airflow.providers.google.cloud.triggers.dataflow.DataflowJobMetricsTrigger
View Docs Source
T

DataflowJobStateCompleteTrigger

Trigger that monitors if a Dataflow job has reached any of successful terminal state meant for that job.

airflow.providers.google.cloud.triggers.dataflow.DataflowJobStateCompleteTrigger
View Docs Source
T

DataflowJobStatusTrigger

Trigger that monitors if a Dataflow job has reached any of the expected statuses.

airflow.providers.google.cloud.triggers.dataflow.DataflowJobStatusTrigger
View Docs Source
T

DataflowStartYamlJobTrigger

Dataflow trigger that checks the state of a Dataflow YAML job.

airflow.providers.google.cloud.triggers.dataflow.DataflowStartYamlJobTrigger
View Docs Source
T

TemplateJobStartTrigger

Dataflow trigger to check if templated job has been finished.

airflow.providers.google.cloud.triggers.dataflow.TemplateJobStartTrigger
View Docs Source
T

DataFusionStartPipelineTrigger

Trigger to perform checking the pipeline status until it reaches terminate state.

airflow.providers.google.cloud.triggers.datafusion.DataFusionStartPipelineTrigger
View Docs Source
T

DataplexDataProfileJobTrigger

DataplexDataProfileJobTrigger runs on the trigger worker and waits for the job to be `SUCCEEDED` state.

airflow.providers.google.cloud.triggers.dataplex.DataplexDataProfileJobTrigger
View Docs Source
T

DataplexDataQualityJobTrigger

DataplexDataQualityJobTrigger runs on the trigger worker and waits for the job to be `SUCCEEDED` state.

airflow.providers.google.cloud.triggers.dataplex.DataplexDataQualityJobTrigger
View Docs Source
T

DataprocBaseTrigger

Base class for Dataproc triggers.

airflow.providers.google.cloud.triggers.dataproc.DataprocBaseTrigger
View Docs Source
T

DataprocBatchTrigger

DataprocCreateBatchTrigger run on the trigger worker to perform create Build operation.

airflow.providers.google.cloud.triggers.dataproc.DataprocBatchTrigger
View Docs Source
T

DataprocClusterTrigger

DataprocClusterTrigger run on the trigger worker to perform create Build operation.

airflow.providers.google.cloud.triggers.dataproc.DataprocClusterTrigger
View Docs Source
T

DataprocDeleteClusterTrigger

DataprocDeleteClusterTrigger run on the trigger worker to perform delete cluster operation.

airflow.providers.google.cloud.triggers.dataproc.DataprocDeleteClusterTrigger
View Docs Source
T

DataprocOperationTrigger

Trigger that periodically polls information on a long running operation from Dataproc API to verify status.

airflow.providers.google.cloud.triggers.dataproc.DataprocOperationTrigger
View Docs Source
T

DataprocSubmitJobDirectTrigger

Trigger that submits a Dataproc job and polls for its completion.

airflow.providers.google.cloud.triggers.dataproc.DataprocSubmitJobDirectTrigger
View Docs Source
T

DataprocSubmitTrigger

DataprocSubmitTrigger run on the trigger worker to perform create Build operation.

airflow.providers.google.cloud.triggers.dataproc.DataprocSubmitTrigger
View Docs Source
T

GCSBlobTrigger

A trigger that fires and it finds the requested file or folder present in the given bucket.

airflow.providers.google.cloud.triggers.gcs.GCSBlobTrigger
View Docs Source
T

GCSCheckBlobUpdateTimeTrigger

A trigger that makes an async call to GCS to check whether the object is updated in a bucket.

airflow.providers.google.cloud.triggers.gcs.GCSCheckBlobUpdateTimeTrigger
View Docs Source
T

GCSPrefixBlobTrigger

Looks for objects in bucket matching a prefix.

airflow.providers.google.cloud.triggers.gcs.GCSPrefixBlobTrigger
View Docs Source
T

GCSUploadSessionTrigger

Return Trigger Event if the inactivity period has passed with no increase in the number of objects.

airflow.providers.google.cloud.triggers.gcs.GCSUploadSessionTrigger
View Docs Source
T

GKEJobTrigger

GKEJobTrigger run on the trigger worker to check the state of Job.

airflow.providers.google.cloud.triggers.kubernetes_engine.GKEJobTrigger
View Docs Source
T

GKEOperationTrigger

Trigger which checks status of the operation.

airflow.providers.google.cloud.triggers.kubernetes_engine.GKEOperationTrigger
View Docs Source
T

GKEStartPodTrigger

Trigger for checking pod status until it finishes its job.

airflow.providers.google.cloud.triggers.kubernetes_engine.GKEStartPodTrigger
View Docs Source
T

PubsubPullTrigger

Initialize the Pubsub Pull Trigger with needed parameters.

airflow.providers.google.cloud.triggers.pubsub.PubsubPullTrigger
View Docs Source
T

CloudBatchJobFinishedTrigger

Cloud Batch trigger to check if templated job has been finished.

airflow.providers.google.cloud.triggers.cloud_batch.CloudBatchJobFinishedTrigger
View Docs Source
T

AgentEngineQueryJobTrigger

Trigger that waits until a Vertex AI Agent Engine query job completes.

airflow.providers.google.cloud.triggers.vertex_ai.AgentEngineQueryJobTrigger
View Docs Source
T

CreateBatchPredictionJobTrigger

CreateBatchPredictionJobTrigger run on the trigger worker to perform create operation.

airflow.providers.google.cloud.triggers.vertex_ai.CreateBatchPredictionJobTrigger
View Docs Source
T

CreateHyperparameterTuningJobTrigger

CreateHyperparameterTuningJobTrigger run on the trigger worker to perform create operation.

airflow.providers.google.cloud.triggers.vertex_ai.CreateHyperparameterTuningJobTrigger
View Docs Source
T

CustomContainerTrainingJobTrigger

Make async calls to Vertex AI to check the state of a running custom container training job.

airflow.providers.google.cloud.triggers.vertex_ai.CustomContainerTrainingJobTrigger
View Docs Source
T

CustomJobTrigger

Trigger that waits until a Vertex AI Custom job completes.

airflow.providers.google.cloud.triggers.vertex_ai.CustomJobTrigger
View Docs Source
T

CustomPythonPackageTrainingJobTrigger

Make async calls to Vertex AI to check the state of a running custom python package training job.

airflow.providers.google.cloud.triggers.vertex_ai.CustomPythonPackageTrainingJobTrigger
View Docs Source
T

CustomTrainingJobTrigger

Make async calls to Vertex AI to check the state of a running custom training job.

airflow.providers.google.cloud.triggers.vertex_ai.CustomTrainingJobTrigger
View Docs Source
T

RunPipelineJobTrigger

Make async calls to Vertex AI to check the state of a Pipeline Job.

airflow.providers.google.cloud.triggers.vertex_ai.RunPipelineJobTrigger
View Docs Source
T

GenAIGeminiCreateBatchJobTrigger

Trigger that creates Gemini Batch Job and waiting for execution.

airflow.providers.google.cloud.triggers.gen_ai.GenAIGeminiCreateBatchJobTrigger
View Docs Source
T

GenAIGeminiCreateEmbeddingsBatchJobTrigger

Trigger that creates Gemini Embeddings Batch Job and waiting for execution.

airflow.providers.google.cloud.triggers.gen_ai.GenAIGeminiCreateEmbeddingsBatchJobTrigger
View Docs Source
B

GCSDagBundle

GCS Dag bundle - exposes a directory in GCS as a Dag bundle.

airflow.providers.google.cloud.bundles.gcs.GCSDagBundle
View Docs Source
X

PrestoToGCSOperator

Copy data from PrestoDB to Google Cloud Storage in JSON, CSV or Parquet format.

airflow.providers.google.cloud.transfers.presto_to_gcs.PrestoToGCSOperator
View Docs Source
X

TrinoToGCSOperator

Copy data from TrinoDB to Google Cloud Storage in JSON, CSV or Parquet format.

airflow.providers.google.cloud.transfers.trino_to_gcs.TrinoToGCSOperator
View Docs Source
X

GCSToGoogleDriveOperator

Copies objects from a Google Cloud Storage service to a Google Drive service, with renaming if requested.

airflow.providers.google.suite.transfers.gcs_to_gdrive.GCSToGoogleDriveOperator
View Docs Source
X

GoogleDriveToGCSOperator

Writes a Google Drive file into Google Cloud Storage.

airflow.providers.google.cloud.transfers.gdrive_to_gcs.GoogleDriveToGCSOperator
View Docs Source
X

AzureFileShareToGCSOperator

Sync an Azure FileShare directory with a Google Cloud Storage destination path.

airflow.providers.google.cloud.transfers.azure_fileshare_to_gcs.AzureFileShareToGCSOperator
View Docs Source
X

CassandraToGCSOperator

Copy data from Cassandra to Google Cloud Storage in JSON format.

airflow.providers.google.cloud.transfers.cassandra_to_gcs.CassandraToGCSOperator
View Docs Source
X

MongoToGCSOperator

Copy data from MongoDB to Google Cloud Storage in JSON, CSV or Parquet format.

airflow.providers.google.cloud.transfers.mongo_to_gcs.MongoToGCSOperator
View Docs Source
X

GoogleCalendarToGCSOperator

Writes Google Calendar data into Google Cloud Storage.

airflow.providers.google.cloud.transfers.calendar_to_gcs.GoogleCalendarToGCSOperator
View Docs Source
X

GoogleSheetsToGCSOperator

Writes Google Sheet data into Google Cloud Storage.

airflow.providers.google.cloud.transfers.sheets_to_gcs.GoogleSheetsToGCSOperator
View Docs Source
X

S3ToGCSOperator Deferrable

Synchronizes an S3 key, possibly a prefix, with a Google Cloud Storage destination path.

airflow.providers.google.cloud.transfers.s3_to_gcs.S3ToGCSOperator
View Docs Source
X

GCSToSFTPOperator

Transfer files from a Google Cloud Storage bucket to SFTP server.

airflow.providers.google.cloud.transfers.gcs_to_sftp.GCSToSFTPOperator
View Docs Source
X

PostgresToGCSOperator

Copy data from Postgres to Google Cloud Storage in JSON, CSV or Parquet format.

airflow.providers.google.cloud.transfers.postgres_to_gcs.PostgresToGCSOperator
View Docs Source
X

BigQueryToSqlBaseOperator

Fetch data from a BigQuery table (alternatively fetch selected columns) and insert it into an SQL table.

airflow.providers.google.cloud.transfers.bigquery_to_sql.BigQueryToSqlBaseOperator
View Docs Source
X

BigQueryToMySqlOperator

Fetch data from a BigQuery table (alternatively fetch selected columns) and insert it into a MySQL table.

airflow.providers.google.cloud.transfers.bigquery_to_mysql.BigQueryToMySqlOperator
View Docs Source
X

BigQueryToMsSqlOperator

Fetch data from a BigQuery table (alternatively fetch selected columns) and insert it into a MSSQL table.

airflow.providers.google.cloud.transfers.bigquery_to_mssql.BigQueryToMsSqlOperator
View Docs Source
X

BigQueryToPostgresOperator

Fetch data from a BigQuery table (alternatively fetch selected columns) and insert into PostgreSQL table.

airflow.providers.google.cloud.transfers.bigquery_to_postgres.BigQueryToPostgresOperator
View Docs Source
X

GCSToBigQueryOperator Deferrable

Loads files from Google Cloud Storage into BigQuery.

airflow.providers.google.cloud.transfers.gcs_to_bigquery.GCSToBigQueryOperator
View Docs Source
X

GCSToGCSOperator

Copies objects from a bucket to another, with renaming if requested.

airflow.providers.google.cloud.transfers.gcs_to_gcs.GCSToGCSOperator
View Docs Source
X

FacebookAdsReportToGcsOperator

Fetch from Facebook Ads API.

airflow.providers.google.cloud.transfers.facebook_ads_to_gcs.FacebookAdsReportToGcsOperator
View Docs Source
X

SFTPToGCSOperator

Transfer files to Google Cloud Storage from SFTP server.

airflow.providers.google.cloud.transfers.sftp_to_gcs.SFTPToGCSOperator
View Docs Source
X

ADLSToGCSOperator

Synchronizes an Azure Data Lake Storage path with a GCS bucket.

airflow.providers.google.cloud.transfers.adls_to_gcs.ADLSToGCSOperator
View Docs Source
X

BigQueryToBigQueryOperator

Copies data from one BigQuery table to another.

airflow.providers.google.cloud.transfers.bigquery_to_bigquery.BigQueryToBigQueryOperator
View Docs Source
X

MySQLToGCSOperator

Copy data from MySQL to Google Cloud Storage in JSON, CSV or Parquet format.

airflow.providers.google.cloud.transfers.mysql_to_gcs.MySQLToGCSOperator
View Docs Source
X

OracleToGCSOperator

Copy data from Oracle to Google Cloud Storage in JSON, CSV or Parquet format.

airflow.providers.google.cloud.transfers.oracle_to_gcs.OracleToGCSOperator
View Docs Source
X

GCSToGoogleSheetsOperator

Uploads .csv file from Google Cloud Storage to provided Google Spreadsheet.

airflow.providers.google.suite.transfers.gcs_to_sheets.GCSToGoogleSheetsOperator
View Docs Source
X

SQLToGoogleSheetsOperator

Copy data from SQL results to provided Google Spreadsheet.

airflow.providers.google.suite.transfers.sql_to_sheets.SQLToGoogleSheetsOperator
View Docs Source
X

LocalFilesystemToGCSOperator

Uploads a file or list of files to Google Cloud Storage; optionally can compress the file for upload; optionally can upload the data in multiple chunks.

airflow.providers.google.cloud.transfers.local_to_gcs.LocalFilesystemToGCSOperator
View Docs Source
X

BigQueryToGCSOperator Deferrable

Transfers a BigQuery table to a Google Cloud Storage bucket.

airflow.providers.google.cloud.transfers.bigquery_to_gcs.BigQueryToGCSOperator
View Docs Source
X

GCSToLocalFilesystemOperator

Downloads a file from Google Cloud Storage.

airflow.providers.google.cloud.transfers.gcs_to_local.GCSToLocalFilesystemOperator
View Docs Source
X

GoogleDriveToLocalOperator

Writes a Google Drive file into local Storage.

airflow.providers.google.cloud.transfers.gdrive_to_local.GoogleDriveToLocalOperator
View Docs Source
X

LocalFilesystemToGoogleDriveOperator

Upload a list of files to a Google Drive folder.

airflow.providers.google.suite.transfers.local_to_drive.LocalFilesystemToGoogleDriveOperator
View Docs Source
X

SalesforceToGcsOperator

Submits Salesforce query and uploads results to Google Cloud Storage.

airflow.providers.google.cloud.transfers.salesforce_to_gcs.SalesforceToGcsOperator
View Docs Source
X

MSSQLToGCSOperator

Copy data from Microsoft SQL Server to Google Cloud Storage in JSON, CSV or Parquet format.

airflow.providers.google.cloud.transfers.mssql_to_gcs.MSSQLToGCSOperator
View Docs Source
X

AzureBlobStorageToGCSOperator

Operator transfers data from Azure Blob Storage to specified bucket in Google Cloud Storage.

airflow.providers.google.cloud.transfers.azure_blob_to_gcs.AzureBlobStorageToGCSOperator
View Docs Source
X

HttpToGCSOperator

Calls an endpoint on an HTTP system to execute an action and store the result in GCS.

airflow.providers.google.cloud.transfers.http_to_gcs.HttpToGCSOperator
View Docs Source
K

CloudSecretManagerBackend

Retrieves Connection object from Google Cloud Secrets Manager.

airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend
View Docs Source
L

GCSTaskHandler

GCSTaskHandler is a python log handler that handles and reads task instance logs.

airflow.providers.google.cloud.log.gcs_task_handler.GCSTaskHandler
View Docs Source
L

CloudLoggingTaskHandler

Handler that directly makes Cloud Logging API calls.

airflow.providers.google.cloud.log.cloud_logging_task_handler.CloudLoggingTaskHandler
View Docs Source
Q

PubSubMessageQueueEventTriggerContainer

Configuration for PubSub integration with common-messaging.

airflow.providers.google.event_scheduling.events.pubsub.PubSubMessageQueueEventTriggerContainer
View Docs Source