apache-airflow-providers-google
Changelog¶
10.22.0¶
Note
This release of provider is only available for Airflow 2.8+ as explained in the Apache Airflow providers support policy.
Features¶
Add 'CloudRunServiceHook' and 'CloudRunCreateServiceOperator' (#40008)
Bug Fixes¶
fix(providers/google): add missing sync_hook_class to CloudDataTransferServiceAsyncHook (#41417)
Misc¶
Bump minimum Airflow version in providers to Airflow 2.8.0 (#41396)Refactor 'DataprocCreateBatchOperator' (#41527)Upgrade package gcloud-aio-auth>=5.2.0 (#41262)
10.21.1¶
Bug Fixes¶
fix unnecessary imports for CloudSQL hook (#41009)Move sensitive information to the secret manager for the system test google_analytics_admin (#40951)Fix Custom Training Job operators to accept results without managed model (#40685)Fix behavior for reattach_state parameter in BigQueryInsertJobOperator (#40664)Fix CloudSQLDatabaseHook temp file handling (#41092)
Misc¶
Refactor dataproc system tests (#40720)openlineage: migrate OpenLineage provider to V2 facets. (#39530)Resolve CloudSQLDatabaseHook deprecation warning (#40834)Fix BeamRunJavaPipelineOperator fails without job_name set (#40645)
10.21.0¶
Note
The change Fix 'GCSToGCSOperator' behavior difference for moving single object (#40162) has
been reverted as it turned out to break too much existing workflows. The behavior of the
GCSToGCSOperator has been restored to the previous behavior.
Features¶
Update Google Cloud Generative Model Hooks/Operators to bring parity with Vertex AI API (#40484)DataflowStartFlexTemplateOperator. Check for Dataflow job type each check cycle. (#40584)Added chunk_size parameter to LocalFilesystemToGCSOperator (#40379)Add support for query parameters to BigQueryCheckOperator (#40558)Add link button to dataproc job in DataprocCreateBatchOperator (#40643)
Bug Fixes¶
Revert "Fix 'GCSToGCSOperator' behavior difference for moving single object (#40162)" (#40577)fix BigQueryInsertJobOperator's return value and openlineage extraction in deferrable mode (#40457)fix OpenLineage extraction for GCP deferrable operators (#40521)fix respect project_id in CloudBatchSubmitJobOperator (#40560)
10.20.0¶
Note
The GCSToGCSOperator now retains the nested folder structure when moving or copying a single
object, aligning its behavior with the behavior for multiple objects. If this change impacts your
workflows, you may need to adjust your source_object parameter to include the full path up to
the folder containing your single file and specify destination_object explicitly to ignore
nested folders. For example, if you previously used source_object='folder/nested_folder/', to
move file 'folder/nested_folder/second_nested_folder/file' you should now use
source_object='folder/nested_folder/second_nested_folder/' and specify
destination_object='folder/nested_folder/'. This would move the file to 'folder/nested_folder/file'
instead of the fixed behavior of moving it to 'folder/nested_folder/second_nested_folder/file'.
Warning
The change above has been reverted in the 10.21.0 release. The behavior of the
GCSToGCSOperator has been restored to the previous behavior.
Features¶
Add generation_config and safety_settings to google cloud multimodal model operators (#40126)Add missing location param to 'BigQueryUpdateTableSchemaOperator' (#40237)Add support for external IdP OIDC token retrieval for Google Cloud Operators. (#39873)Add encryption_configuration parameter to BigQuery operators (#40063)Add default gcp_conn_id to GoogleBaseAsyncHook (#40080)Add ordering key option for PubSubPublishMessageOperator GCP Operator (#39955)Add method to get metadata from GCS blob in GCSHook (#38398)Add window parameters to create_auto_ml_forecasting_training_job in AutoMLHook (#39767)Implement CloudComposerDAGRunSensor (#40088)Implement 'CloudDataTransferServiceRunJobOperator' (#39154)Fetch intermediate log async GKEStartPod (#39348)Add OpenLineage support for AzureBlobStorageToGCSOperator in google provider package (#40290)
Bug Fixes¶
Fix hive_partition_sensor system test (#40023)Fix openai 1.32 breaking openai tests (#40110)Fix credentials initialization revealed by mypy version of google auth (#40108)Fix regular expression to exclude double quote and newline in DataflowHook (#39991)Fix replace parameter for BigQueryToPostgresOperator (#40278)Fix 'GCSToGCSOperator' behavior difference for moving single object (#40162)
Misc¶
Refactor datapipeline operators (#39716)Update pandas minimum requirement for Python 3.12 (#40272)implement per-provider tests with lowest-direct dependency resolution (#39946)openlineage: execute extraction and message sending in separate process (#40078)Bump minimum version of google-auth to 2.29.0 (#40190)Bump google-ads version to use v17 by default (#40158)google: move openlineage imports inside methods (#40062)Add job_id as template_field in DataplexGetDataQualityScanResultOperator (#40041)Add dependency to httpx >= 0.25.0 everywhere (#40256)
10.19.0¶
Note
Several AutoML operators have stopped being supported following the shutdown of a legacy version of
AutoML Natural Language, Tables, Vision, and Video Intelligence services. This includes
AutoMLDeployModelOperator, AutoMLTablesUpdateDatasetOperator, AutoMLTablesListTableSpecsOperator
and AutoMLTablesListColumnSpecsOperator. Please refer to the operator documentation to find out
about available alternatives, if any. For additional information regarding the AutoML shutdown see:
Features¶
Introduce anonymous credentials in GCP base hook (#39695)
Bug Fixes¶
Remove parent_model version suffix if it is passed to Vertex AI operators (#39640)Fix BigQueryCursor execute method if the location is missing (#39659)Fix acknowledged functionality in deferrable mode for PubSubPullSensor (#39711)Reroute AutoML operator links to Google Translation links (#39668)Pin google-cloud-bigquery to < 3.21.0 (#39583)
Misc¶
Remove 'openlineage.common' dependencies in Google and Snowflake providers. (#39614)Deprecate AutoML Tables operators (#39752)Resolve deprecation warnings in Azure FileShare-to-GCS tests (#39599)typo: wrong OpenLineage facet key in spec (#39782)removed stale code from StackdriverTaskHandler (#39744)
10.18.0¶
Note
This release of provider is only available for Airflow 2.7+ as explained in the Apache Airflow providers support policy.
Features¶
add templated fields for google llm operators (#39174)Add logic to handle on_kill for BigQueryInsertJobOperator when deferrable=True (#38912)Create 'CloudComposerRunAirflowCLICommandOperator' operator (#38965)Deferrable mode for Dataflow sensors (#37693)Deferrable mode for Custom Training Job operators (#38584)Enhancement for SSL-support in CloudSQLExecuteQueryOperator (#38894)Create GKESuspendJobOperator and GKEResumeJobOperator operators (#38677)Add support for role arn for aws creds in Google Transfer Service operator (#38911)Add encryption_configuration parameter to BigQueryCheckOperator and BigQueryTableCheckOperator (#39432)Add 'job_id' parameter to 'BigQueryGetDataOperator' (#39315)
Bug Fixes¶
Fix deferrable mode for DataflowTemplatedJobStartOperator and DataflowStartFlexTemplateOperator (#39018)Fix batching for BigQueryToPostgresOperator (#39233)Fix DataprocSubmitJobOperator in deferrable mode=True when task is marked as failed. (#39230)Fix GCSObjectExistenceSensor operator to return the same XCOM value in deferrable and non-deferrable mode (#39206)Fix conn_id BigQueryToMsSqlOperator (#39171)Fix add retry logic in case of google auth refresh credential error (#38961)Fix BigQueryCheckOperator skipped value and error check in deferrable mode (#38408)Fix Use prefixes instead of all file paths for OpenLineage datasets in GCSDeleteObjectsOperator (#39059)Fix Use prefixes instead of full file paths for OpenLineage datasets in GCSToGCSOperator (#39058)Fix OpenLineage datasets in GCSTimeSpanFileTransformOperator (#39064)Fix generation temp filename in 'DataprocSubmitPySparkJobOperator' (#39498)Fix logic to cancel the external job if the TaskInstance is not in a running or deferred state for DataprocSubmitJobOperator (#39447)Fix logic to cancel the external job if the TaskInstance is not in a running or deferred state for BigQueryInsertJobOperator (#39442)Fix logic to cancel the external job if the TaskInstance is not in a running or deferred state for DataprocCreateClusterOperator (#39446)Fix 'DataprocCreateBatchOperator' with 'result_retry' raises 'AttributeError' (#39462)Fix yaml parsing for GKEStartKueueInsideClusterOperator (#39234)Fix validation of label values in BigQueryInsertJobOperator (#39568)
Misc¶
Bump minimum Airflow version in providers to Airflow 2.7.0 (#39240)Improve 'DataprocCreateClusterOperator' Triggers for Better Error Handling and Resource Cleanup (#39130)Adding MSGraphOperator in Microsoft Azure provider (#38111)Apply PROVIDE_PROJECT_ID mypy workaround across Google provider (#39129)handle KubernetesDeleteJobOperator import (#39036)Remove Airflow 2.6 back compact code (#39558)Reapply templates for all providers (#39554)Faster 'airflow_version' imports (#39552)Add deprecation warnings and raise exception for already deprecated ones (#38673)Simplify 'airflow_version' imports (#39497)Disconnect GKE operators from deprecated hooks (#39434)
10.17.0¶
Features¶
Add 'impersonation_scopes' to BigQuery (#38169)Add the deferrable mode to RunPipelineJobOperator (#37969)Add GKECreateCustomResourceOperator and GKEDeleteCustomResourceOperator operators (#37616)Add VertexAI Language Model and Multimodal Model Operators for Google Cloud Generative AI use (#37721)Add GKEListJobsOperator and GKEDescribeJobOperator (#37598)Create GKEStartKueueJobOperator operator (#37477)Create DeleteKubernetesJobOperator and GKEDeleteJobOperator operators (#37793)Update GCS hook to get crc32c hash for CMEK-protected objects (#38191)Set job labels for traceability in BigQuery jobs (#37736)Deferrable mode for CreateBatchPredictionJobOperator (#37818)
Bug Fixes¶
Fix BigQuery connection and add docs (#38430)fix(google,log): Avoid log name overriding (#38071)Fix credentials error for S3ToGCSOperator trigger (#37518)Fix 'parent_model' parameter in GCP Vertex AI AutoML and Custom Job operators (#38417)fix(google): add return statement to yield within a while loop in triggers (#38394)Fix cursor unique name surpasses Postgres identifier limit in 'PostgresToGCSOperator' (#38040)Fix gcs Anonymous user issue because none token (#38102)Fix BigQueryTablePartitionExistenceTrigger partition query (#37655)
Misc¶
Add google-cloud-bigquery as explicit google-provider dependency (#38753)Avoid to use 'functools.lru_cache' in class methods in 'google' provider (#38652)Refactor GKE hooks (#38404)Remove unused loop variable from airflow package (#38308)templated fields logic checks for cloud_storage_transfer_service (#37519)Rename mlengine's operators' fields' names to comply with templated fields validation (#38053)Rename Vertex AI AutoML operators fields' names to comply with templated fields validation (#38049)Rename 'DeleteCustomTrainingJobOperator''s fields' names to comply with templated fields validation (#38048)Restore delegate_to for Google Transfer Operators retrieving from Google Cloud. (#37925)Refactor CreateHyperparameterTuningJobOperator (#37938)Upgrade google-ads version (#37787)
10.16.0¶
Features¶
'CloudRunExecuteJobOperator': Add project_id to hook.get_job calls (#37201)Add developer token as authentication method to GoogleAdsHook (#37417)Add GKEStartKueueInsideClusterOperator (#37072)Add optional 'location' parameter to the BigQueryInsertJobTrigger (#37282)feat(GKEPodAsyncHook): use async credentials token implementation (#37486)Create GKEStartJobOperator and KubernetesJobOperator (#36847)
Bug Fixes¶
Fix invalid deprecation of 'DataFusionPipelineLinkHelper' (#37755)fix templated field assignment 'google/cloud/operators/compute.py' (#37659)fix bq_to_mysql init checks (#37653)Fix Async GCSObjectsWithPrefixExistenceSensor xcom push (#37634)Fix GCSSynchronizeBucketsOperator timeout error (#37237)fix: Signature of insert_rows incompatible with supertype DbApiHook (#37391)Use offset-naive datetime in _CredentialsToken (#37539)Use wait_for_operation in DataprocInstantiateInlineWorkflowTemplateOperator (#37145)
Misc¶
Fix typo on DataflowStartFlexTemplateOperator documentation (#37595)Make 'executemany' keyword arguments only in 'DbApiHook.insert_rows' (#37840)Unify 'aws_conn_id' type to always be 'str | None' (#37768)Limit 'pandas' to '<2.2' (#37748)Remove broken deprecated fallback into the Google provider operators (#37740)Implement AIP-60 Dataset URI formats (#37005)resolve template fields init checks for 'bigquery' (#37586)Update docs for the DataprocCreateBatchOperator (#37562)Replace usage of 'datetime.utcnow' and 'datetime.utcfromtimestamp' in providers (#37138)
10.15.0¶
Features¶
add service_file support to GKEPodAsyncHook (#37081)Update GCP Dataproc ClusterGenerator to support GPU params (#37036)Create DataprocStartClusterOperator and DataprocStopClusterOperator (#36996)Implement deferrable mode for CreateHyperparameterTuningJobOperator (#36594)Enable '_enable_tcp_keepalive' functionality for GKEPodHook (#36999)
Bug Fixes¶
fix(providers/google): fix how GKEPodAsyncHook.service_file_as_context is used (#37306)Fix metadata override for ComputeEngineSSHHook (#37192)Fix assignment of template field in '__init__' in 'custom_job' (#36789)Fix location requirement in DataflowTemplatedJobStartOperator (#37069)Fix assignment of template field in '__init__' in 'CloudDataTransferServiceCreateJobOperator' (#36909)Fixed the hardcoded default namespace value for GCP Data Fusion links. (#35379)Do not ignore the internal_ip_only if set to false in Dataproc cluster config (#37014)
Misc¶
Revert protection against back-compatibility issue with google-core-api (#37111)feat: Switch all class, functions, methods deprecations to decorators (#36876)
10.14.0¶
Note
The default value of parquet_row_group_size in BaseSQLToGCSOperator has changed from 1 to
100000, in order to have a default that provides better compression efficiency and performance of
reading the data in the output Parquet files. In many cases, the previous value of 1 resulted in
very large files, long task durations and out of memory issues. A default value of 100000 may require
more memory to execute the operator, in which case users can override the parquet_row_group_size
parameter in the operator. All operators that are derived from BaseSQLToGCSOperator are affected
when export_format is parquet: MySQLToGCSOperator, PrestoToGCSOperator,
OracleToGCSOperator, TrinoToGCSOperator, MSSQLToGCSOperator and PostgresToGCSOperator. Due to the above we treat this change as bug fix.
Features¶
Add templated fields to 'BigQueryToSqlBaseOperator' from 'BigQueryToPostgresOperator' (#36663)Added Check for Cancel Workflow Invocation and added new Query Workflow Invocation operator (#36351)Implement Google Analytics Admin (GA4) operators (#36276)Add operator to diagnose cluster (#36899)Add scopes into a GCP token (#36974)feat: full support for google credentials in gcloud-aio clients (#36849)
Bug Fixes¶
fix templating field to super constructor (#36934)fix: respect connection ID and impersonation in GKEStartPodOperator (#36861)Fix stacklevel in warnings.warn into the providers (#36831)Fix deprecations into the GCP Dataproc links (#36834)fix assignment of templated field in constructor (#36603)Check cluster state before defer Dataproc operators to trigger (#36892)prevent templated field logic checks in operators __init__ (#36489)Preserve ASCII control characters directly through the BigQuery load API (#36533)Change default 'parquet_row_group_size' in 'BaseSQLToGCSOperator' (#36817)Fix google operators handling of impersonation chain (#36903)
Misc¶
style(providers/google): improve BigQueryInsertJobOperator type hinting (#36894)Deprecate AutoMLTrainModelOperator for Vision and Video (#36473)Remove backward compatibility check for KubernetesPodOperator module (#36724)Remove backward compatibility check for KubernetesPodTrigger module (#36721)Set min pandas dependency to 1.2.5 for all providers and airflow (#36698)remove unnecessary templated field (#36491)docs(providers/google): reword GoogleBaseHookAsync as GoogleBaseAsyncHook in docstring (#36946)
10.13.1¶
Misc¶
Remove backcompat code for stackdriver (#36442)Remove unused '_parse_version' function (#36450)Remove remaining Airflow 2.5 backcompat code from GCS Task Handler (#36443) (#36457)
10.13.0¶
Note
This release of provider is only available for Airflow 2.6+ as explained in the Apache Airflow providers support policy.
Features¶
GCP Secrets Backend Impersonation (#36072)Add OpenLineage support to GcsOperators - Delete, Transform and TimeSpanTransform (#35838)Add support for service account impersonation with computeEngineSSHHook (google provider) and IAP tunnel (#35136)Add Datascan Profiling (#35696)Add overrides to template fields of Google Cloud Run Jobs Execute Operator (#36133)Implement deferrable mode for BeamRunJavaPipelineOperator (#36122)Add ability to run streaming Job for BeamRunPythonPipelineOperator in non deferrable mode (#36108)Add use_glob to GCSObjectExistenceSensor (#34137)
Bug Fixes¶
Fix DataprocSubmitJobOperator to retrieve failed job error message (#36053)Fix CloudRunExecuteJobOperator not able to retrieve the Cloud Run job status in deferrable mode (#36012)Fix gcs listing - ensure blobs are loaded (#34919)allow multiple elements in impersonation chain (#35694)Change retry type for Google Dataflow Client to async one (#36141)Minor fix to DataprocCreateClusterOperator operator docs. (#36322)fix(bigquery.py): pass correct project_id to triggerer (#35200)iterate through blobs before checking prefixes (#36202)Fix incompatibility with google-cloud-monitoring 2.18.0 (#36200)Update 'retry' param typing in PubSubAsyncHook (#36198)
Misc¶
Bump minimum Airflow version in providers to Airflow 2.6.0 (#36017)Deprecate 'CloudComposerEnvironmentSensor' in favor of 'CloudComposerCreateEnvironmentOperator' with defer mode (#35775)Follow BaseHook connection fields method signature in child classes (#36086)Allow storage options to be passed (#35820)Add feature to build "chicken-egg" packages from sources (#35890)Remove remaining Airflow 2.5 backcompat code from Google Provider (#36366)Move KubernetesPodTrigger hook to a cached property (#36290)Add code snippet formatting in docstrings via Ruff (#36262)
10.12.0¶
Features¶
added Topic params for schema_settings and message_retention_duration. (#35767)Add OpenLineage support to GCSToBigQueryOperator (#35778)Add OpenLineage support to BigQueryToGCSOperator (#35660)Add support for driver pool, instance flexibility policy, and min_num_instances for Dataproc (#34172)Add "NON_PREEMPTIBLE" as a valid preemptibility type for Dataproc workers (#35669)Add ability to pass impersonation_chain to BigQuery triggers (#35629)Add a filter for local files in GoogleDisplayVideo360CreateQueryOperator (#35635)Extend task context logging support for remote logging using GCP GCS (#32970)
Bug Fixes¶
Fix and reapply templates for provider documentation (#35686)Fix the logic of checking dataflow job state (#34785)
Misc¶
Remove usage of deprecated method from BigQueryToBigQueryOperator (#35605)Check attr on parent not self re TaskContextLogger set_context (#35780)Remove backcompat with Airflow 2.3/2.4 in providers (#35727)Restore delegate_to param in GoogleDiscoveryApiHook (#35728)Remove usage of deprecated methods from BigQueryCursor (#35606)Align documentation of 'MSSQLToGCSOperator' (#35715)
10.11.0¶
Features¶
AIP-58: Add Airflow ObjectStore (AFS) (#34729)Improve Dataprep hook (#34880)
Misc¶
Added 'overrides' parameter to CloudRunExecuteJobOperator (#34874)
10.10.1¶
Misc¶
Add links between documentation related to Google Cloud Storage (#34994)Migrate legacy version of AI Platform Prediction to VertexAI (#34922)Cancel workflow in on_kill in DataprocInstantiate{Inline}WorkflowTemplateOperator (#34957)
10.10.0¶
Note
This release of provider is only available for Airflow 2.5+ as explained in the Apache Airflow providers support policy.
Features¶
improvement: introduce project_id in BigQueryIntervalCheckOperator (#34573)
Bug Fixes¶
respect soft_fail argument when exception is raised for google sensors (#34501)Fix GCSToGoogleDriveOperator and gdrive system tests (#34545)Fix LookerHook serialize missing 1 argument error (#34678)Fix Dataform system tests (#34329)
Misc¶
Bump min airflow version of providers (#34728)Refactor DataFusionInstanceLink usage (#34514)Use 'airflow.models.dag.DAG' in Google Provider examples (#34614)Deprecate Life Sciences Operator and Hook (#34549)Use 'airflow.exceptions.AirflowException' in providers (#34511)
10.9.0¶
Features¶
Add explicit support of stream (realtime) pipelines for CloudDataFusionStartPipelineOperator (#34271)Add 'expected_terminal_state' parameter to Dataflow operators (#34217)
Bug Fixes¶
Fix 'ComputeEngineInsertInstanceOperator' doesn't respect jinja-templated instance name when given in body argument (#34171)fix: BigQuery job error message (#34208)GKEPodHook ignores gcp_conn_id parameter. (#34194)
Misc¶
Bump min common-sql provider version for Google provider (#34257)Remove unnecessary call to keys() method on dictionaries (#34260)Refactor: Think positively in providers (#34279)Refactor: Simplify code in providers/google (#33229)Refactor: Simplify comparisons (#34181)Deprecate AutoMLTrainModelOperator for NL (#34212)Simplify to bool(...) (#34258)Make Google Dataform operators templated_fields more consistent (#34187)
10.8.0¶
Features¶
Add deferrable mode to Dataplex DataQuality. (#33954)allow impersonation_chain to be set on Google Cloud connection (#33715)
Bug Fixes¶
fix(providers/google-marketing-platform): respect soft_fail argument when exception is raised (#34165)fix: docstring in endpoint_service.py (#34135)Fix BigQueryValueCheckOperator deferrable mode optimisation (#34018)Dynamic setting up of artifact versions for Datafusion pipelines (#34068)Early delete a Dataproc cluster if started in the ERROR state. (#33668)Avoid blocking event loop when using DataFusionAsyncHook by replacing sleep by asyncio.sleep (#33756)
Misc¶
Consolidate importing of os.path.* (#34060)Refactor regex in providers (#33898)Move the try outside the loop when this is possible in Google provider (#33976)Combine similar if logics in providers (#33987)Remove useless string join from providers (#33968)Update Azure fileshare hook to use azure-storage-file-share instead of azure-storage-file (#33904)Refactor unneeded jumps in providers (#33833)replace loop by any when looking for a positive value in providers (#33984)Replace try - except pass by contextlib.suppress in providers (#33980)Remove some useless try/except from providers code (#33967)Replace sequence concatenation by unpacking in Airflow providers (#33933)Remove a deprecated option from 'BigQueryHook.get_pandas_df' (#33819)replace unnecessary dict comprehension by dict() in providers (#33857)Improve modules import in google provider by move some of them into a type-checking block (#33783)Use a single statement with multiple contexts instead of nested statements in providers (#33768)Use literal dict instead of calling dict() in providers (#33761)remove unnecessary and rewrite it using list in providers (#33763)Refactor: Simplify a few loops (#33736)E731: replace lambda by a def method in Airflow providers (#33757)Use f-string instead of in Airflow providers (#33752)
10.7.0¶
Features¶
Add CloudRunHook and operators (#33067)Add 'CloudBatchHook' and operators (#32606)Adding Support for Google Cloud's Data Pipelines Run Operator (#32846)Add parameter sftp_prefetch to SFTPToGCSOperator (#33274)Add Google Cloud's Data Pipelines Create Operator (#32843)Add Dataplex Data Quality operators. (#32256)
Bug Fixes¶
Fix BigQueryCreateExternalTableOperator when using a foramt different to CSV (#33540)Fix DataplexDataQualityJobStatusSensor and add unit tests (#33440)Avoid importing pandas and numpy in runtime and module level (#33483)
Misc¶
Add missing template fields to DataformCreateCompilationResultOperator (#33585)Consolidate import and usage of pandas (#33480)Import utc from datetime and normalize its import (#33450)
10.6.0¶
Features¶
openlineage, bigquery: add openlineage method support for BigQueryExecuteQueryOperator (#31293)Add GCS Requester Pays bucket support to GCSToS3Operator (#32760)Add system test and docs for CloudDataTransferServiceGCSToGCSOperator (#32960)Add a new parameter to SQL operators to specify conn id field (#30784)
Bug Fixes¶
Fix 'DataFusionAsyncHook' catch 404 (#32855)Fix system test for MetastoreHivePartitionSensor (#32861)Fix catching 409 error (#33173)make 'sql' a cached property in 'BigQueryInsertJobOperator' (#33218)
Misc¶
refactor(providers.google): use module level __getattr__ for DATAPROC_JOB_LOG_LINK to DATAPROC_JOB_LINK and add deprecation warning (#33189)
10.5.0¶
Features¶
openlineage, gcs: add openlineage methods for GcsToGcsOperator (#31350)Add Spot Instances support with Dataproc Operators (#31644)Install sqlalchemy-spanner package into Google provider (#31925)Filtering and ordering results of DataprocListBatchesOperator (#32500)
Bug Fixes¶
Fix BigQueryGetDataOperator where project_id is not being respected in deferrable mode (#32488)Refresh GKE OAuth2 tokens (#32673)Fix 'BigQueryInsertJobOperator' not exiting deferred state (#31591)
Misc¶
Fixup docstring for deprecated DataprocSubmitSparkJobOperator and refactoring system tests (#32743)Add more accurate typing for DbApiHook.run method (#31846)Add deprecation info to the providers modules and classes docstring (#32536)Fixup docstring for deprecated DataprocSubmitHiveJobOperator (#32723)Fixup docstring for deprecated DataprocSubmitPigJobOperator (#32739)Fix Datafusion system tests (#32749)
10.4.0¶
Features¶
Implement deferrable mode for S3ToGCSOperator (#29462)
Bug Fixes¶
Bugfix GCSToGCSOperator when copy files to folder without wildcard (#32486)Fix 'cache_control' parameter of upload function in 'GCSHook' (#32440)Fix BigQuery transfer operators to respect project_id arguments (#32232)Fix the gcp_gcs_delete_objects on empty list (#32383)Fix endless loop of defer in cloud_build (#32387)Fix GCSToGCSOperator copy without wildcard and exact_match=True (#32376)
Misc¶
Allow a destination folder to be provided (#31885)Moves 'AzureBlobStorageToGCSOperator' from Azure to Google provider (#32306)Give better link to job configuration docs in BigQueryInsertJobOperator (#31736)
10.3.0¶
Features¶
Add 'on_finish_action' to 'KubernetesPodOperator' (#30718)Add deferrable mode to CloudSQLExportInstanceOperator (#30852)Adding 'src_fmt_configs' to the list of template fields. (#32097)
Bug Fixes¶
[Issue-32069] Fix name format in the batch requests (#32070)Fix 'BigQueryInsertJobOperator' error handling in deferrable mode (#32034)Fix 'BIGQUERY_JOB_DETAILS_LINK_FMT' in 'BigQueryConsoleLink' (#31953)Make the deferrable version of DataprocCreateBatchOperator handle a batch_id that already exists (#32216)
Misc¶
Switch Google Ads API version from v13 to v14 (#32028)Deprecate 'delimiter' param and source object's wildcards in GCS, introduce 'match_glob' param. (#31261)Refactor GKECreateClusterOperator's body validation (#31923)Optimize deferrable mode execution for 'BigQueryValueCheckOperator' (#31872)Add default_deferrable config (#31712)
10.2.0¶
Note
This release dropped support for Python 3.7
Features¶
add a return when the event is yielded in a loop to stop the execution (#31985)Add deferrable mode to PubsubPullSensor (#31284)Add a new param to set parquet row group size in 'BaseSQLToGCSOperator' (#31831)Add 'cacheControl' field to google cloud storage (#31338)Add 'preserveAsciiControlCharacters' to 'src_fmt_configs' (#31643)Add support for credential configuation file auth to Google Secrets Manager secrets backend (#31597)Add credential configuration file support to Google Cloud Hook (#31548)Add deferrable mode to 'GCSUploadSessionCompleteSensor' (#31081)Add append_job_name parameter in DataflowStartFlexTemplateOperator (#31511)FIPS environments: Mark uses of md5 as "not-used-for-security" (#31171)Implement MetastoreHivePartitionSensor (#31016)
Bug Fixes¶
Bigquery: fix links for already existing tables and datasets. (#31589)Provide missing project id and creds for TabularDataset (#31991)
Misc¶
Optimize deferrable mode execution for 'DataprocSubmitJobOperator' (#31317)Optimize deferrable mode execution for 'BigQueryInsertJobOperator' (#31249)Remove return statement after yield from triggers class (#31703)Replace unicodecsv with standard csv library (#31693)Optimize deferrable mode (#31758)Remove Python 3.7 support (#30963)
10.1.1¶
Bug Fixes¶
Fix accessing a GKE cluster through the private endpoint in 'GKEStartPodOperator' (#31391)Fix 'BigQueryGetDataOperator''s query job bugs in deferrable mode (#31433)
10.1.0¶
Note
This release of provider is only available for Airflow 2.4+ as explained in the Apache Airflow providers support policy.
Note
This release changed default Google ads to v13. Since v12 is deprecated by Google and soon to be removed we are not consider this to be a breaking change in Airflow.
Note
This version of the provider bumped many Google packages. Please review packages change logs
Features¶
Add deferrable mode to DataprocInstantiateInlineWorkflowTemplateOperator (#30878)Add deferrable mode to 'GCSObjectUpdateSensor' (#30579)Add protocol to define methods relied upon by KubernetesPodOperator (#31298)Add BigQueryToPostgresOperator (#30658)
Bug Fixes¶
'DataflowTemplatedJobStartOperator' fix overwriting of location with default value, when a region is provided. (#31082)Poke once before defer for GCSObjectsWithPrefixExistenceSensor (#30939)Add deferrable mode to 'GCSObjectsWithPrefixExistenceSensor' (#30618)allow multiple prefixes in gcs delete/list hooks and operators (#30815)Fix removed delegate_to parameter in deferrable GCS sensor (#30810)
Misc¶
Add 'use_legacy_sql' param to 'BigQueryGetDataOperator' (#31190)Add 'as_dict' param to 'BigQueryGetDataOperator' (#30887)Add flag apply_gcs_prefix to S3ToGCSOperator (b/245077385) (#31127)Add 'priority' parameter to BigQueryHook (#30655)Bump minimum Airflow version in providers (#30917)implement gcs_schema_object for BigQueryCreateExternalTableOperator (#30961)Optimize deferred execution mode (#30946)Optimize deferrable mode execution (#30920)Optimize deferrable mode in 'GCSObjectExistenceSensor' (#30901)'CreateBatchPredictionJobOperator' Add batch_size param for Vertex AI BatchPredictionJob objects (#31118)GKEPodHook needs to have all methods KPO calls (#31266)Add CloudBuild build id log (#30516)Switch default Google ads to v13 (#31382)Switch to google ads v13 (#31369)Update SDKs for google provider package (#30067)
10.0.0¶
Breaking changes¶
Google has announced sunset of Campaign Manager 360 v3.5 by Apr 20, 2023. For more information please check: https://developers.google.com/doubleclick-advertisers/deprecation . As a result, the default api version for Campaign Manager 360 operator was updated to the latest v4 version.
Warning
In this version of the provider, deprecated delegate_to param is removed from all GCP operators, hooks, and triggers, as well as from firestore and gsuite
transfer operators that interact with GCS. Impersonation can be achieved instead by utilizing the impersonation_chain param.
The delegate_to param will still be available only in gsuite and marketing platform hooks and operators, that don’t interact with Google Cloud.
remove delegate_to from GCP operators and hooks (#30748)Update Google Campaign Manager360 operators to use API v4 (#30598)
Bug Fixes¶
Update DataprocCreateCluster operator to use 'label' parameter properly (#30741)
Misc¶
add missing project_id in BigQueryGetDataOperator (#30651)Display Video 360 cleanup v1 API usage (#30577)
9.0.0¶
Breaking changes¶
Google announced sunset of Bid manager API v1 and v1.1 by April 27, 2023 for more information please check: docs As a result default value of api_version in GoogleDisplayVideo360Hook and related operators updated to v2
This version of provider contains a temporary workaround to issue with v11 version of
google-ads API being discontinued, while the google provider dependencies preventing installing
any google-ads client supporting v12 API. This version contains vendored-in version of google-ads
library 20.0.0 v12 support only. The workaround (and vendored-in library) will be removed
as soon as dependencies of the provider will allow to use google-ads supporting newer
API versions of google-ads.
Note
ONLY v12 version of google ads is supported. You should set v12 when your create an operator or client.
Update DV360 operators to use API v2 (#30326)Fix dynamic imports in google ads vendored in library (#30544)Fix one more dynamic import needed for vendored-in google ads (#30564)
Features¶
Add deferrable mode to GKEStartPodOperator (#29266)
Bug Fixes¶
BigQueryHook list_rows/get_datasets_list can return iterator (#30543)Fix cloud build async credentials (#30441)
8.12.0¶
Features¶
Add missing 'poll_interval' in Bigquery operator (#30132)Add poll_interval param in BigQueryInsertJobOperator (#30091)Add 'job_id' to 'BigQueryToGCSOperator' templated_fields (#30006)Support deleting the local log files when using remote logging (#29772)
Bug Fixes¶
fix setting project_id for gs to bq and bq to gs (#30053)Fix location on cloud build operators (#29937)'GoogleDriveHook': Fixing log message + adding more verbose documentation (#29694)Add "BOOLEAN" to type_map of MSSQLToGCSOperator, fix incorrect bit->int type conversion by specifying BIT fields explicitly (#29902)Google Cloud Providers - Fix _MethodDefault deepcopy failure (#29518)Handling project location param on async BigQuery dts trigger (#29786)Support CloudDataTransferServiceJobStatusSensor without specifying a project_id (#30035)Wait insert_job result in normal mode (#29925)
Misc¶
merge BigQueryTableExistenceAsyncSensor into BigQueryTableExistenceSensor (#30235)Remove unnecessary upper constraints from google provider (#29915)Merge BigQueryTableExistencePartitionAsyncSensor into BigQueryTableExistencePartitionSensor (#30231)Merge GCSObjectExistenceAsyncSensor logic to GCSObjectExistenceSensor (#30014)Align cncf provider file names with AIP-21 (#29905)Switch to using vendored-in google ads. (#30410)Merging of the google ads vendored-in code. (#30399)
8.11.0¶
Features¶
Add deferrable mode to BigQueryTablePartitionExistenceSensor. (#29735)Add a new param for BigQuery operators to support additional actions when resource exists (#29394)Add deferrable mode to DataprocInstantiateWorkflowTemplateOperator (#28618)Dataproc batches (#29136)Add 'CloudSQLCloneInstanceOperator' (#29726)
Bug Fixes¶
Fix 'NoneType' object is not subscriptable. (#29820)Fix and augment 'check-for-inclusive-language' CI check (#29549)Don't push secret in XCOM in BigQueryCreateDataTransferOperator (#29348)
Misc¶
Google Cloud Providers - Introduce GoogleCloudBaseOperator (#29680)Update google cloud dlp package and adjust hook and operators (#29234)Refactor Dataproc Trigger (#29364)Remove <2.0.0 limit on google-cloud-bigtable (#29644)Move help message to the google auth code (#29888)
8.10.0¶
Features¶
Add defer mode to GKECreateClusterOperator and GKEDeleteClusterOperator (#28406)
Bug Fixes¶
Move cloud_sql_binary_path from connection to Hook (#29499)Check that cloud sql provider version is valid (#29497)'GoogleDriveHook': Add folder_id param to upload_file (#29477)
Misc¶
Add documentation for BigQuery transfer operators (#29466)
8.9.0¶
Features¶
Add deferrable capability to existing ''DataprocDeleteClusterOperator'' (#29349)Add deferrable mode to dataflow operators (#27776)Add deferrable mode to DataprocCreateBatchOperator (#28457)Add deferrable mode to DataprocCreateClusterOperator and DataprocUpdateClusterOperator (#28529)Add deferrable mode to MLEngineStartTrainingJobOperator (#27405)Add deferrable mode to DataFusionStartPipelineOperator (#28690)Add deferrable mode for Big Query Transfer operator (#27833)Add support for write_on_empty in BaseSQLToGCSOperator (#28959)Add DataprocCancelOperationOperator (#28456)Enable individual trigger logging (#27758)Auto ML assets (#25466)
Bug Fixes¶
Fix GoogleDriveHook writing files to trashed folders on upload v2 (#29119)fix Google provider CHANGELOG.rst (#29122)fix Google provider CHANGELOG.rst (#29114)Keyfile dict can be dict not str (#29135)GCSTaskHandler may use remote log conn id (#29117)
Misc¶
Deprecate 'delegate_to' param in GCP operators and update docs (#29088)
8.8.0¶
Features¶
Add deferrable ''GCSObjectExistenceSensorAsync'' (#28763)Support partition_columns in BaseSQLToGCSOperator (#28677)
Bug Fixes¶
'BigQueryCreateExternalTableOperator' fix field delimiter not working with csv (#28856)Fix using private _get_credentials instead of public get_credentials (#28588)Fix'GoogleCampaignManagerReportSensor' with 'QUEUED' status (#28735)Fix BigQueryColumnCheckOperator runtime error (#28796)assign "datasetReference" attribute to dataset_reference dict. by default if not already set in create_empty_dataset method of bigquery hook (#28782)
8.7.0¶
Features¶
Add table_resource to template fields for BigQueryCreateEmptyTableOperator (#28235)Add retry param in GCSObjectExistenceSensor (#27943)Add preserveAsciiControlCharacters to src_fmt_configs (#27679)Add deferrable mode to CloudBuildCreateBuildOperator (#27783)GCSToBigQueryOperator allows autodetect None and infers schema (#28564)Improve memory usage in Dataproc deferrable operators (#28117)Push job_id in xcom for dataproc submit job op (#28639)
Bug Fixes¶
Fix for issue with reading schema fields for JSON files in GCSToBigQueryOperator (#28284)Fix GCSToBigQueryOperator not respecting schema_obj (#28444)Fix GCSToGCSOperator copying list of objects without wildcard (#28111)Fix: re-enable use of parameters in gcs_to_bq which had been disabled (#27961)Set bigquery ''use_legacy_sql'' param in job config correctly (#28522)
Misc¶
Remove 'pylint' messages control instructions (#28555)Remove deprecated AIPlatformConsoleLinkk from google/provider.yaml (#28449)Use object instead of array in config.yml for config template (#28417)[misc] Get rid of 'pass' statement in conditions (#27775)Change log level to DEBUG when secret not found for google secret manager (#27856)[misc] Replace XOR '^' conditions by 'exactly_one' helper in providers (#27858)
8.6.0¶
Features¶
Persist DataprocLink for workflow operators regardless of job status (#26986)Deferrable mode for BigQueryToGCSOperator (#27683)Add Export Format to Template Fields in BigQueryToGCSOperator (#27910)
Bug Fixes¶
Fix to read location parameter properly in BigQueryToBigQueryOperator (#27661)Bump common.sql provider to 1.3.1 (#27888)
8.5.0¶
Note
This release of provider is only available for Airflow 2.3+ as explained in the Apache Airflow providers support policy.
Misc¶
Move min airflow version to 2.3.0 for all providers (#27196)Rename hook bigquery function '_bq_cast' to 'bq_cast' (#27543)Use non-deprecated method for on_kill in BigQueryHook (#27547)Typecast biquery job response col value (#27236)Remove <2 limit on google-cloud-storage (#26922)Replace urlparse with urlsplit (#27389)
Features¶
When defining a connection in environment variables or secrets backend, previously extra fields
needed to be defined with prefix extra__google_cloud_platform__. Now this is no longer required.
So for example you may store the keyfile json as keyfile_dict instead of
extra__google_cloud_platform__keyfile_dict. If both are present, the short name will be preferred.
Add backward compatibility with old versions of Apache Beam (#27263)Add deferrable mode to GCSToBigQueryOperator + tests (#27052)Add system tests for Vertex AI operators in new approach (#27053)Dataform operators, links, update system tests and docs (#27144)Allow values in WorkflowsCreateExecutionOperator execution argument to be dicts (#27361)DataflowStopJobOperator Operator (#27033)Allow for the overriding of stringify_dict for json/jsonb column data type in Postgres #26875 (#26876)Allow and prefer non-prefixed extra fields for dataprep hook (#27039)Update google hooks to prefer non-prefixed extra fields (#27023)
Bug Fixes¶
Add new Compute Engine Operators and fix system tests (#25608)Common sql bugfixes and improvements (#26761)Fix delay in Dataproc CreateBatch operator (#26126)Remove unnecessary newlines around single arg in signature (#27525)set project_id and location when canceling BigQuery job (#27521)use the proper key to retrieve the dataflow job_id (#27336)Make GSheetsHook return an empty list when there are no values (#27261)Cloud ML Engine operators assets (#26836)
8.4.0¶
Features¶
Add BigQuery Column and Table Check Operators (#26368)Add deferrable big query operators and sensors (#26156)Add 'output' property to MappedOperator (#25604)Added append_job_name parameter to DataflowTemplatedJobStartOperator (#25746)Adding a parameter for exclusion of trashed files in GoogleDriveHook (#25675)Cloud Data Loss Prevention Operators assets (#26618)Cloud Storage Transfer Operators assets & system tests migration (AIP-47) (#26072)Merge deferrable BigQuery operators to exisitng one (#26433)specifying project id when calling wait_for_operation in delete/create cluster (#26418)Auto tail file logs in Web UI (#26169)Cloud Functions Operators assets & system tests migration (AIP-47) (#26073)GCSToBigQueryOperator Resolve 'max_id_key' job retrieval and xcom return (#26285)Allow for the overriding of 'stringify_dict' for json export format on BaseSQLToGCSOperator (#26277)Append GoogleLink base in the link class (#26057)Cloud Video Intelligence Operators assets & system tests migration (AIP-47) (#26132)Life Science assets & system tests migration (AIP-47) (#25548)GCSToBigQueryOperator allow for schema_object in alternate GCS Bucket (#26190)Use AsyncClient for Composer Operators in deferrable mode (#25951)Use project_id to get authenticated client (#25984)Cloud Build assets & system tests migration (AIP-47) (#25895)Dataproc submit job operator async (#25302)Support project_id argument in BigQueryGetDataOperator (#25782)
Bug Fixes¶
Fix JSONDecodeError in Datafusion operators (#26202)Fixed never ending loop to in CreateWorkflowInvocation (#25737)Update gcs.py (#26570)Don't throw an exception when a BQ cusor job has no schema (#26096)Google Cloud Tasks Sensor for queue being empty (#25622)Correcting the transfer config name. (#25719)Fix parsing of optional 'mode' field in BigQuery Result Schema (#26786)Fix MaxID logic for GCSToBigQueryOperator (#26768)
Misc¶
Sql to GSC operators update docs for parquet format (#25878)Limit Google Protobuf for compatibility with biggtable client (#25886)Make GoogleBaseHook credentials functions public (#25785)Consolidate to one 'schedule' param (#25410)
8.3.0¶
Features¶
add description method in BigQueryCursor class (#25366)Add project_id as a templated variable in two BQ operators (#24768)Remove deprecated modules in Amazon provider (#25543)Move all "old" SQL operators to common.sql providers (#25350)Improve taskflow type hints with ParamSpec (#25173)Unify DbApiHook.run() method with the methods which override it (#23971)Bump typing-extensions and mypy for ParamSpec (#25088)Deprecate hql parameters and synchronize DBApiHook method APIs (#25299)Dataform operators (#25587)
Bug Fixes¶
Fix GCSListObjectsOperator docstring (#25614)Fix BigQueryInsertJobOperator cancel_on_kill (#25342)Fix BaseSQLToGCSOperator approx_max_file_size_bytes (#25469)Fix PostgresToGCSOperat bool dtype (#25475)Fix Vertex AI Custom Job training issue (#25367)Fix Flask Login user setting for Flask 2.2 and Flask-Login 0.6.2 (#25318)
8.2.0¶
Features¶
PubSub assets & system tests migration (AIP-47) (#24867)Add handling state of existing Dataproc batch (#24924)Add links for Google Kubernetes Engine operators (#24786)Add test_connection method to 'GoogleBaseHook' (#24682)Add gcp_conn_id argument to GoogleDriveToLocalOperator (#24622)Add DeprecationWarning for column_transformations parameter in AutoML (#24467)Modify BigQueryCreateExternalTableOperator to use updated hook function (#24363)Move all SQL classes to common-sql provider (#24836)Datacatalog assets & system tests migration (AIP-47) (#24600)Upgrade FAB to 4.1.1 (#24399)
Bug Fixes¶
GCSDeleteObjectsOperator empty prefix bug fix (#24353)perf(BigQuery): pass table_id as str type (#23141)Update providers to use functools compat for ''cached_property'' (#24582)
8.1.0¶
Features¶
Update Oracle library to latest version (#24311)Expose SQL to GCS Metadata (#24382)
Bug Fixes¶
fix typo in google provider additional extras (#24431)Use insert_job in the BigQueryToGCPOpertor and adjust links (#24416)
8.0.0¶
Breaking changes¶
Note
This release of provider is only available for Airflow 2.2+ as explained in the Apache Airflow providers support policy.
Features¶
Add key_secret_project_id parameter which specifies a project with KeyFile (#23930)Added impersonation_chain for DataflowStartFlexTemplateOperator and DataflowStartSqlJobOperator (#24046)Add fields to CLOUD_SQL_EXPORT_VALIDATION. (#23724)Update credentials when using ADC in Compute Engine (#23773)set color to operators in cloud_sql.py (#24000)Sql to gcs with exclude columns (#23695)[Issue#22846] allow option to encode or not encode UUID when uploading from Cassandra to GCS (#23766)Workflows assets & system tests migration (AIP-47) (#24105)Spanner assets & system tests migration (AIP-47) (#23957)Speech To Text assets & system tests migration (AIP-47) (#23643)Cloud SQL assets & system tests migration (AIP-47) (#23583)Cloud Storage assets & StorageLink update (#23865)
Bug Fixes¶
fix BigQueryInsertJobOperator (#24165)Fix the link to google workplace (#24080)Fix DataprocJobBaseOperator not being compatible with dotted names (#23439). (#23791)Remove hack from BigQuery DTS hook (#23887)Fix GCSToGCSOperator cannot copy a single file/folder without copying other files/folders with that prefix (#24039)Workaround job race bug on biguery to gcs transfer (#24330)
Misc¶
Fix BigQuery system tests (#24013)Ensure @contextmanager decorates generator func (#23103)Migrate Dataproc to new system tests design (#22777)AIP-47 - Migrate google leveldb DAGs to new design ##22447 (#24233)Apply per-run log templates to log handlers (#24153)
7.0.0¶
Breaking changes¶
Remove deprecated parameters from PubSub operators: (#23261)Upgrade to support Google Ads v10 (#22965)'DataprocJobBaseOperator' changes (#23350)'DataprocJobBaseOperator': order of parameters has changed.'region' parameter has no default value affected functions/classes: 'DataprocHook.cancel_job' 'DataprocCreateClusterOperator' 'DataprocJobBaseOperator'
'DatastoreHook': Remove 'datastore_conn_id'. Please use 'gcp_conn_id' (#23323)'CloudBuildCreateBuildOperator': Remove 'body'. Please use 'build' (#23263)Replica cluster id removal (#23251)'BigtableCreateInstanceOperator' Remove 'replica_cluster_id', 'replica_cluster_zone'. Please use 'replica_clusters''BigtableHook.create_instance': Remove 'replica_cluster_id', 'replica_cluster_zone'. Please use 'replica_clusters'
Remove params (#23230)'GoogleDisplayVideo360CreateReportOperator': Remove 'params'. Please use 'parameters''FacebookAdsReportToGcsOperator': Remove 'params'. Please use 'parameters'
'GoogleDriveToGCSOperator': Remove 'destination_bucket' and 'destination_object'. Please use 'bucket_name' and 'object_name' (#23072)'GCSObjectsWtihPrefixExistenceSensor' removed. Please use 'GCSObjectsWithPrefixExistenceSensor' (#23050)Remove 'project': (#23231)'PubSubCreateTopicOperator': Remove 'project'. Please use 'project_id''PubSubCreateSubscriptionOperator': Remove 'topic_project'. Please use 'project_id''PubSubCreateSubscriptionOperator': Remove 'subscription_project'. Please use 'subscription_project_id''PubSubDeleteTopicOperator': Remove 'project'. Please use 'project_id''PubSubDeleteSubscriptionOperator': Remove 'project'. Please use 'project_id''PubSubPublishMessageOperator': Remove 'project'. Please use 'project_id''PubSubPullSensor': Remove 'project'. Please use 'project_id''PubSubPullSensor': Remove 'return_immediately'
Remove 'location' - replaced with 'region' (#23250)'DataprocJobSensor': Remove 'location'. Please use 'region''DataprocCreateWorkflowTemplateOperator': Remove 'location'. Please use 'region''DataprocCreateClusterOperator': Remove 'location'. Please use 'region''DataprocSubmitJobOperator': Remove 'location'. Please use 'region''DataprocHook': Remove 'location' parameter. Please use 'region'Affected functions are:'cancel_job''create_workflow_template''get_batch_client''get_cluster_client''get_job''get_job_client''get_template_client''instantiate_inline_workflow_template''instantiate_workflow_template''submit_job''update_cluster''wait_for_job'
'DataprocHook': Order of parameters in 'wait_for_job' function has changed'DataprocSubmitJobOperator': order of parameters has changed.
Removal of xcom_push (#23252)'CloudDatastoreImportEntitiesOperator': Remove 'xcom_push'. Please use 'BaseOperator.do_xcom_push''CloudDatastoreExportEntitiesOperator': Remove 'xcom_push'. Please use 'BaseOperator.do_xcom_push'
'bigquery_conn_id' and 'google_cloud_storage_conn_id' is removed. Please use 'gcp_conn_id' (#23326).Affected classes:'BigQueryCheckOperator''BigQueryCreateEmptyDatasetOperator''BigQueryDeleteDatasetOperator''BigQueryDeleteTableOperator''BigQueryExecuteQueryOperator''BigQueryGetDataOperator''BigQueryHook''BigQueryIntervalCheckOperator''BigQueryTableExistenceSensor''BigQueryTablePartitionExistenceSensor''BigQueryToBigQueryOperator''BigQueryToGCSOperator''BigQueryUpdateTableSchemaOperator''BigQueryUpsertTableOperator''BigQueryValueCheckOperator''GCSToBigQueryOperator''ADLSToGCSOperator''BaseSQLToGCSOperator''CassandraToGCSOperator''GCSBucketCreateAclEntryOperator''GCSCreateBucketOperator''GCSDeleteObjectsOperator''GCSHook''GCSListObjectsOperator''GCSObjectCreateAclEntryOperator''GCSToBigQueryOperator''GCSToGCSOperator''GCSToLocalFilesystemOperator''LocalFilesystemToGCSOperator'
'S3ToGCSOperator': Remove 'dest_gcs_conn_id'. Please use 'gcp_conn_id' (#23348)'BigQueryHook' changes (#23269)'BigQueryHook.create_empty_table' Remove 'num_retries'. Please use 'retry''BigQueryHook.run_grant_dataset_view_access' Remove 'source_project'. Please use 'project_id'
'DataprocHook': Remove deprecated function 'submit' (#23389)
Features¶
[FEATURE] google provider - BigQueryInsertJobOperator log query (#23648)[FEATURE] google provider - split GkeStartPodOperator execute (#23518)Add exportContext.offload flag to CLOUD_SQL_EXPORT_VALIDATION. (#23614)Create links for BiqTable operators (#23164)implements #22859 - Add .sql as templatable extension (#22920)'GCSFileTransformOperator': New templated fields 'source_object', 'destination_object' (#23328)
Bug Fixes¶
Fix 'PostgresToGCSOperator' does not allow nested JSON (#23063)Fix GCSToGCSOperator ignores replace parameter when there is no wildcard (#23340)update processor to fix broken download URLs (#23299)'LookerStartPdtBuildOperator', 'LookerCheckPdtBuildSensor' : fix empty materialization id handling (#23025)Change ComputeSSH to throw provider import error instead paramiko (#23035)Fix cancel_on_kill after execution timeout for DataprocSubmitJobOperator (#22955)Fix select * query xcom push for BigQueryGetDataOperator (#22936)MSSQLToGCSOperator fails: datetime is not JSON Serializable (#22882)
Misc¶
Add Stackdriver assets and migrate system tests to AIP-47 (#23320)CloudTasks assets & system tests migration (AIP-47) (#23282)TextToSpeech assets & system tests migration (AIP-47) (#23247)Fix code-snippets in google provider (#23438)Bigquery assets (#23165)Remove redundant docstring in 'BigQueryUpdateTableSchemaOperator' (#23349)Migrate gcs to new system tests design (#22778)add missing docstring in 'BigQueryHook.create_empty_table' (#23270)Cleanup Google provider CHANGELOG.rst (#23390)migrate system test gcs_to_bigquery into new design (#22753)Add example DAG for demonstrating usage of GCS sensors (#22808)Clean up in-line f-string concatenation (#23591)Bump pre-commit hook versions (#22887)Use new Breese for building, pulling and verifying the images. (#23104)Fix new MyPy errors in main (#22884)
6.8.0¶
Features¶
Add autodetect arg in BQCreateExternalTable Operator (#22710)Add links for BigQuery Data Transfer (#22280)Modify transfer operators to handle more data (#22495)Create Endpoint and Model Service, Batch Prediction and Hyperparameter Tuning Jobs operators for Vertex AI service (#22088)PostgresToGoogleCloudStorageOperator - BigQuery schema type for time zone naive fields (#22536)Update secrets backends to use get_conn_value instead of get_conn_uri (#22348)
Bug Fixes¶
Fix the docstrings (#22497)Fix 'download_media' url in 'GoogleDisplayVideo360SDFtoGCSOperator' (#22479)Fix to 'CloudBuildRunBuildTriggerOperator' fails to find build id. (#22419)Fail ''LocalFilesystemToGCSOperator'' if src does not exist (#22772)Remove coerce_datetime usage from GCSTimeSpanFileTransformOperator (#22501)
Misc¶
Refactor: BigQuery to GCS Operator (#22506)Remove references to deprecated operators/params in PubSub operators (#22519)New design of system tests (#22311)
6.7.0¶
Features¶
Add dataflow_default_options to templated_fields (#22367)Add 'LocalFilesystemToGoogleDriveOperator' (#22219)Add timeout and retry to the BigQueryInsertJobOperator (#22395)
Bug Fixes¶
Fix skipping non-GCS located jars (#22302)[FIX] typo doc of gcs operator (#22290)Fix mistakenly added install_requires for all providers (#22382)
6.6.0¶
Features¶
Support Uploading Bigger Files to Google Drive (#22179)Change the default 'chunk_size' to a clear representation & add documentation (#22222)Add guide for DataprocInstantiateInlineWorkflowTemplateOperator (#22062)Allow for uploading metadata with GCS Hook Upload (#22058)Add Dataplex operators (#20377)
Misc¶
Add support for ARM platform (#22127)Add Trove classifiers in PyPI (Framework :: Apache Airflow :: Provider)Use yaml safe load (#22091)
6.5.0¶
Features¶
Add Looker PDT operators (#20882)Add autodetect arg to external table creation in GCSToBigQueryOperator (#21944)Add Dataproc assets/links (#21756)Add Auto ML operators for Vertex AI service (#21470)Add GoogleCalendarToGCSOperator (#20769)Make project_id argument optional in all dataproc operators (#21866)Allow templates in more DataprocUpdateClusterOperator fields (#21865)Dataflow Assets (#21639)Extract ClientInfo to module level (#21554)Datafusion assets (#21518)Dataproc metastore assets (#21267)Normalize *_conn_id parameters in BigQuery sensors (#21430)
Bug Fixes¶
Fix bigquery_dts parameter docstring typo (#21786)Fixed PostgresToGCSOperator fail on empty resultset for use_server_side_cursor=True (#21307)Fix multi query scenario in bigquery example DAG (#21575)
Misc¶
Support for Python 3.10Unpin 'google-cloud-memcache' (#21912)Unpin ''pandas-gbq'' and remove unused code (#21915)Suppress hook warnings from the Bigquery transfers (#20119)
6.4.0¶
Features¶
Add hook for integrating with Google Calendar (#20542)Add encoding parameter to 'GCSToLocalFilesystemOperator' to fix #20901 (#20919)batch as templated field in DataprocCreateBatchOperator (#20905)Make timeout Optional for wait_for_operation (#20981)Add more SQL template fields renderers (#21237)Create CustomJob and Datasets operators for Vertex AI service (#21253)Support to upload file to Google Shared Drive (#21319)(providers_google) add a location check in bigquery (#19571)Add support for BeamGoPipelineOperator (#20386)Google Cloud Composer opearators (#21251)Enable asynchronous job submission in BigQuery hook (#21385)Optionally raise an error if source file does not exist in GCSToGCSOperator (#21391)
Bug Fixes¶
Cloudsql import links fix. (#21199)Fix BigQueryDataTransferServiceHook.get_transfer_run() request parameter (#21293):bug: (BigQueryHook) fix compatibility with sqlalchemy engine (#19508)
Misc¶
Refactor operator links to not create ad hoc TaskInstances (#21285)
6.3.0¶
Features¶
Add optional location to bigquery data transfer service (#15088) (#20221)Add Google Cloud Tasks how-to documentation (#20145)Added example DAG for MSSQL to Google Cloud Storage (GCS) (#19873)Support regional GKE cluster (#18966)Delete pods by default in KubernetesPodOperator (#20575)
Bug Fixes¶
Fixes docstring for PubSubCreateSubscriptionOperator (#20237)Fix missing get_backup method for Dataproc Metastore (#20326)BigQueryHook fix typo in run_load doc string (#19924)Fix passing the gzip compression parameter on sftp_to_gcs. (#20553)switch to follow_redirects on httpx.get call in CloudSQL provider (#20239)avoid deprecation warnings in BigQuery transfer operators (#20502)Change download_video parameter to resourceName (#20528)Fix big query to mssql/mysql transfer issues (#20001)Fix setting of project ID in ''provide_authorized_gcloud'' (#20428)
Misc¶
Move source_objects datatype check out of GCSToBigQueryOperator.__init__ (#20347)Organize S3 Classes in Amazon Provider (#20167)Providers facebook hook multiple account (#19377)Remove deprecated method call (blob.download_as_string) (#20091)Remove deprecated template_fields from GoogleDriveToGCSOperator (#19991)
Note! optional features of the apache-airflow-providers-facebook and apache-airflow-providers-amazon
require newer versions of the providers (as specified in the dependencies)
6.2.0¶
Features¶
Added wait mechanizm to the DataprocJobSensor to avoid 509 errors when Job is not available (#19740)Add support in GCP connection for reading key from Secret Manager (#19164)Add dataproc metastore operators (#18945)Add support of 'path' parameter for GCloud Storage Transfer Service operators (#17446)Move 'bucket_name' validation out of '__init__' in Google Marketing Platform operators (#19383)Create dataproc serverless spark batches operator (#19248)updates pipeline_timeout CloudDataFusionStartPipelineOperator (#18773)Support impersonation_chain parameter in the GKEStartPodOperator (#19518)
Bug Fixes¶
Fix badly merged impersonation in GKEPodOperator (#19696)
6.1.0¶
Features¶
Add value to 'namespaceId' of query (#19163)Add pre-commit hook for common misspelling check in files (#18964)Support query timeout as an argument in CassandraToGCSOperator (#18927)Update BigQueryCreateExternalTableOperator doc and parameters (#18676)Replacing non-attribute template_fields for BigQueryToMsSqlOperator (#19052)Upgrade the Dataproc package to 3.0.0 and migrate from v1beta2 to v1 api (#18879)Use google cloud credentials when executing beam command in subprocess (#18992)Replace default api_version of FacebookAdsReportToGcsOperator (#18996)Dataflow Operators - use project and location from job in on_kill method. (#18699)
Bug Fixes¶
Fix hard-coded /tmp directory in CloudSQL Hook (#19229)Fix bug in Dataflow hook when no jobs are returned (#18981)Fix BigQueryToMsSqlOperator documentation (#18995)Move validation of templated input params to run after the context init (#19048)Google provider catch invalid secret name (#18790)
6.0.0¶
Breaking changes¶
Migrate Google Cloud Build from Discovery API to Python SDK (#18184)
Features¶
Add index to the dataset name to have separate dataset for each example DAG (#18459)Add missing __init__.py files for some test packages (#18142)Add possibility to run DAGs from system tests and see DAGs logs (#17868)Rename AzureDataLakeStorage to ADLS (#18493)Make next_dagrun_info take a data interval (#18088)Use parameters instead of params (#18143)New google operator: SQLToGoogleSheetsOperator (#17887)
Bug Fixes¶
Fix part of Google system tests (#18494)Fix kubernetes engine system test (#18548)Fix BigQuery system test (#18373)Fix error when create external table using table resource (#17998)Fix ''BigQuery'' data extraction in ''BigQueryToMySqlOperator'' (#18073)Fix providers tests in main branch with eager upgrades (#18040)fix(CloudSqlProxyRunner): don't query connections from Airflow DB (#18006)Remove check for at least one schema in GCSToBigquery (#18150)deduplicate running jobs on BigQueryInsertJobOperator (#17496)
5.1.0¶
Features¶
Add error check for config_file parameter in GKEStartPodOperator (#17700)Gcp ai hyperparameter tuning (#17790)Allow omission of 'initial_node_count' if 'node_pools' is specified (#17820)[Airflow 13779] use provided parameters in the wait_for_pipeline_state hook (#17137)Enable specifying dictionary paths in 'template_fields_renderers' (#17321)Don't cache Google Secret Manager client (#17539)[AIRFLOW-9300] Add DatafusionPipelineStateSensor and aync option to the CloudDataFusionStartPipelineOperator (#17787)
Bug Fixes¶
GCP Secret Manager error handling for missing credentials (#17264)
Misc¶
Optimise connection importing for Airflow 2.2.0Adds secrets backend/logging/auth information to provider yaml (#17625)
5.0.0¶
Breaking changes¶
Updated GoogleAdsHook to support newer API versions after google deprecated v5. Google Ads v8 is the new default API. (#17111)Google Ads Hook: Support newer versions of the google-ads library (#17160)
Warning
The underlying google-ads library had breaking changes.
Previously the google ads library returned data as native protobuf messages. Now it returns data as proto-plus objects that behave more like conventional Python objects.
To preserve compatibility the hook’s search() converts the data back to native protobuf before returning it. Your existing operators should work as before, but due to the urgency of the v5 API being deprecated it was not tested too thoroughly. Therefore you should carefully evaluate your operator and hook functionality with this new version.
In order to use the API’s new proto-plus format, you can use the search_proto_plus() method.
For more information, please consult google-ads migration document:
Features¶
Standardise dataproc location param to region (#16034)Adding custom Salesforce connection type + SalesforceToS3Operator updates (#17162)
Bug Fixes¶
Update alias for field_mask in Google Memmcache (#16975)fix: dataprocpysparkjob project_id as self.project_id (#17075)Fix GCStoGCS operator with replace diabled and existing destination object (#16991)
4.0.0¶
Breaking changes¶
Auto-apply apply_default decorator (#15667)
Warning
Due to apply_default decorator removal, this version of the provider requires Airflow 2.1.0+.
If your Airflow version is < 2.1.0, and you want to install this provider version, first upgrade
Airflow to at least version 2.1.0. Otherwise your Airflow package version will be upgraded
automatically and you will have to manually run airflow upgrade db to complete the migration.
Move plyvel to google provider extra (#15812)Fixes AzureFileShare connection extras (#16388)
Features¶
Add extra links for google dataproc (#10343)add oracle connection link (#15632)pass wait_for_done parameter down to _DataflowJobsController (#15541)Use api version only in GoogleAdsHook not operators (#15266)Implement BigQuery Table Schema Update Operator (#15367)Add BigQueryToMsSqlOperator (#15422)
Bug Fixes¶
Fix: GCS To BigQuery source_object (#16160)Fix: Unnecessary downloads in ``GCSToLocalFilesystemOperator(#16171)``Fix bigquery type error when export format is parquet (#16027)Fix argument ordering and type of bucket and object (#15738)Fix sql_to_gcs docstring lint error (#15730)fix: ensure datetime-related values fully compatible with MySQL and BigQuery (#15026)Fix deprecation warnings location in google provider (#16403)
3.0.0¶
Breaking changes¶
Change in AutoMLPredictOperator¶
The params parameter in airflow.providers.google.cloud.operators.automl.AutoMLPredictOperator class
was renamed operation_params because it conflicted with a param parameter in the BaseOperator class.
Integration with the apache.beam provider¶
In 3.0.0 version of the provider we’ve changed the way of integrating with the apache.beam provider.
The previous versions of both providers caused conflicts when trying to install them together
using PIP > 20.2.4. The conflict is not detected by PIP 20.2.4 and below but it was there and
the version of Google BigQuery python client was not matching on both sides. As the result, when
both apache.beam and google provider were installed, some features of the BigQuery operators
might not work properly. This was cause by apache-beam client not yet supporting the new google
python clients when apache-beam[gcp] extra was used. The apache-beam[gcp] extra is used
by Dataflow operators and while they might work with the newer version of the Google BigQuery
python client, it is not guaranteed.
This version introduces additional extra requirement for the apache.beam extra of the google provider
and symmetrically the additional requirement for the google extra of the apache.beam provider.
Both google and apache.beam provider do not use those extras by default, but you can specify
them when installing the providers. The consequence of that is that some functionality of the Dataflow
operators might not be available.
Unfortunately the only complete solution to the problem is for the apache.beam to migrate to the
new (>=2.0.0) Google Python clients.
This is the extra for the google provider:
extras_require = (
{
# ...
"apache.beam": ["apache-airflow-providers-apache-beam", "apache-beam[gcp]"],
# ...
},
)
And likewise this is the extra for the apache.beam provider:
extras_require = ({"google": ["apache-airflow-providers-google", "apache-beam[gcp]"]},)
You can still run this with PIP version <= 20.2.4 and go back to the previous behaviour:
pip install apache-airflow-providers-google[apache.beam]
or
pip install apache-airflow-providers-apache-beam[google]
But be aware that some BigQuery operators functionality might not be available in this case.
Features¶
[Airflow-15245] - passing custom image family name to the DataProcClusterCreateoperator (#15250)
Bug Fixes¶
Bugfix: Fix rendering of ''object_name'' in ''GCSToLocalFilesystemOperator'' (#15487)Fix typo in DataprocCreateClusterOperator (#15462)Fixes wrongly specified path for leveldb hook (#15453)
2.2.0¶
Features¶
Adds 'Trino' provider (with lower memory footprint for tests) (#15187)update remaining old import paths of operators (#15127)Override project in dataprocSubmitJobOperator (#14981)GCS to BigQuery Transfer Operator with Labels and Description parameter (#14881)Add GCS timespan transform operator (#13996)Add job labels to bigquery check operators. (#14685)Use libyaml C library when available. (#14577)Add Google leveldb hook and operator (#13109) (#14105)
Bug fixes¶
Google Dataflow Hook to handle no Job Type (#14914)
2.1.0¶
Features¶
Corrects order of argument in docstring in GCSHook.download method (#14497)Refactor SQL/BigQuery/Qubole/Druid Check operators (#12677)Add GoogleDriveToLocalOperator (#14191)Add 'exists_ok' flag to BigQueryCreateEmptyTable(Dataset)Operator (#14026)Add materialized view support for BigQuery (#14201)Add BigQueryUpdateTableOperator (#14149)Add param to CloudDataTransferServiceOperator (#14118)Add gdrive_to_gcs operator, drive sensor, additional functionality to drive hook (#13982)Improve GCSToSFTPOperator paths handling (#11284)
Bug Fixes¶
Fixes to dataproc operators and hook (#14086)#9803 fix bug in copy operation without wildcard (#13919)
2.0.0¶
Breaking changes¶
Updated google-cloud-* libraries¶
This release of the provider package contains third-party library updates, which may require updating your DAG files or custom hooks and operators, if you were using objects from those libraries. Updating of these libraries is necessary to be able to use new features made available by new versions of the libraries and to obtain bug fixes that are only available for new versions of the library.
Details are covered in the UPDATING.md files for each library, but there are some details that you should pay attention to.
Library name |
Previous constraints |
Current constraints |
Upgrade Documentation |
|---|---|---|---|
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
The field names use the snake_case convention¶
If your DAG uses an object from the above mentioned libraries passed by XCom, it is necessary to update the naming convention of the fields that are read. Previously, the fields used the CamelSnake convention, now the snake_case convention is used.
Before:
set_acl_permission = GCSBucketCreateAclEntryOperator(
task_id="gcs-set-acl-permission",
bucket=BUCKET_NAME,
entity="user-{{ task_instance.xcom_pull('get-instance')['persistenceIamIdentity'].split(':', 2)[1] }}",
role="OWNER",
)
After:
set_acl_permission = GCSBucketCreateAclEntryOperator(
task_id="gcs-set-acl-permission",
bucket=BUCKET_NAME,
entity="user-{{ task_instance.xcom_pull('get-instance')['persistence_iam_identity']"
".split(':', 2)[1] }}",
role="OWNER",
)
Features¶
Add Apache Beam operators (#12814)Add Google Cloud Workflows Operators (#13366)Replace 'google_cloud_storage_conn_id' by 'gcp_conn_id' when using 'GCSHook' (#13851)Add How To Guide for Dataflow (#13461)Generalize MLEngineStartTrainingJobOperator to custom images (#13318)Add Parquet data type to BaseSQLToGCSOperator (#13359)Add DataprocCreateWorkflowTemplateOperator (#13338)Add OracleToGCS Transfer (#13246)Add timeout option to gcs hook methods. (#13156)Add regional support to dataproc workflow template operators (#12907)Add project_id to client inside BigQuery hook update_table method (#13018)
Bug fixes¶
Fix four bugs in StackdriverTaskHandler (#13784)Decode Remote Google Logs (#13115)Fix and improve GCP BigTable hook and system test (#13896)updated Google DV360 Hook to fix SDF issue (#13703)Fix insert_all method of BigQueryHook to support tables without schema (#13138)Fix Google BigQueryHook method get_schema() (#13136)Fix Data Catalog operators (#13096)
1.0.0¶
Initial version of the provider.