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 <[email protected]>
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)
