You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/04/26 14:21:29 UTC
[airflow] branch main updated: * `CloudDatastoreImportEntitiesOperator` : Remove `xcom_push`. Please use `BaseOperator.do_xcom_push` (#23252)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 710eb6f3e6 * `CloudDatastoreImportEntitiesOperator` : Remove `xcom_push`. Please use `BaseOperator.do_xcom_push` (#23252)
710eb6f3e6 is described below
commit 710eb6f3e606c32aa8a518915d2930abeb69f659
Author: eladkal <45...@users.noreply.github.com>
AuthorDate: Tue Apr 26 17:21:12 2022 +0300
* `CloudDatastoreImportEntitiesOperator` : Remove `xcom_push`. Please use `BaseOperator.do_xcom_push` (#23252)
* `CloudDatastoreExportEntitiesOperator` : Remove `xcom_push`. Please use `BaseOperator.do_xcom_push`
---
airflow/providers/google/CHANGELOG.rst | 4 ++++
airflow/providers/google/cloud/operators/datastore.py | 4 ----
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/airflow/providers/google/CHANGELOG.rst b/airflow/providers/google/CHANGELOG.rst
index a5d39106f5..2023490d98 100644
--- a/airflow/providers/google/CHANGELOG.rst
+++ b/airflow/providers/google/CHANGELOG.rst
@@ -69,6 +69,10 @@ Breaking changes
* ``DataprocSubmitJobOperator``: order of parameters has changed.
+* ``CloudDatastoreImportEntitiesOperator`` : Remove ``xcom_push``. Please use ``BaseOperator.do_xcom_push``
+
+* ``CloudDatastoreExportEntitiesOperator`` : Remove ``xcom_push``. Please use ``BaseOperator.do_xcom_push``
+
6.8.0
.....
diff --git a/airflow/providers/google/cloud/operators/datastore.py b/airflow/providers/google/cloud/operators/datastore.py
index 4d168cb2e1..d36c6d6617 100644
--- a/airflow/providers/google/cloud/operators/datastore.py
+++ b/airflow/providers/google/cloud/operators/datastore.py
@@ -108,8 +108,6 @@ class CloudDatastoreExportEntitiesOperator(BaseOperator):
self.overwrite_existing = overwrite_existing
self.project_id = project_id
self.impersonation_chain = impersonation_chain
- if kwargs.get('xcom_push') is not None:
- raise AirflowException("'xcom_push' was deprecated, use 'BaseOperator.do_xcom_push' instead")
def execute(self, context: 'Context') -> dict:
self.log.info('Exporting data to Cloud Storage bucket %s', self.bucket)
@@ -218,8 +216,6 @@ class CloudDatastoreImportEntitiesOperator(BaseOperator):
self.polling_interval_in_seconds = polling_interval_in_seconds
self.project_id = project_id
self.impersonation_chain = impersonation_chain
- if kwargs.get('xcom_push') is not None:
- raise AirflowException("'xcom_push' was deprecated, use 'BaseOperator.do_xcom_push' instead")
def execute(self, context: 'Context'):
self.log.info('Importing data from Cloud Storage bucket %s', self.bucket)