* CloudDatastoreImportEntitiesOperator : Remove xcom_push. Please…

… use `BaseOperator.do_xcom_push` (#23252) * `CloudDatastoreExportEntitiesOperator` : Remove `xcom_push`. Please use `BaseOperator.do_xcom_push`
apache · Apr 26, 2022 · 710eb6f · 710eb6f
1 parent 2d569fd
commit 710eb6f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -108,8 +108,6 @@ def __init__(
  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 @@ def __init__(
  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)