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 7fde48d0983 Removed deprecated code (#44700)
7fde48d0983 is described below
commit 7fde48d0983bd442f1470c068a3bcc5defdb2a2f
Author: Ajit J Gupta <[email protected]>
AuthorDate: Fri Dec 6 17:32:33 2024 +0530
Removed deprecated code (#44700)
---
.../src/airflow/providers/apache/beam/CHANGELOG.rst | 9 +++++++++
.../airflow/providers/apache/beam/triggers/beam.py | 19 -------------------
2 files changed, 9 insertions(+), 19 deletions(-)
diff --git a/providers/src/airflow/providers/apache/beam/CHANGELOG.rst
b/providers/src/airflow/providers/apache/beam/CHANGELOG.rst
index d5cdfa62370..b51e2a68285 100644
--- a/providers/src/airflow/providers/apache/beam/CHANGELOG.rst
+++ b/providers/src/airflow/providers/apache/beam/CHANGELOG.rst
@@ -26,6 +26,15 @@
Changelog
---------
+main
+.....
+
+.. warning::
+ All deprecated classes, parameters, and features have been removed from the
Airbyte provider package.
+ The following breaking changes were introduced:
+
+ * Removed ``BeamPipelineTrigger`` class from ``trigger``. Use the
``class:`airflow.providers.apache.beam.triggers.beam.BeamPythonPipelineTrigger``
class instead.
+
5.9.1
.....
diff --git a/providers/src/airflow/providers/apache/beam/triggers/beam.py
b/providers/src/airflow/providers/apache/beam/triggers/beam.py
index 92c137d3bb3..3eb3611b613 100644
--- a/providers/src/airflow/providers/apache/beam/triggers/beam.py
+++ b/providers/src/airflow/providers/apache/beam/triggers/beam.py
@@ -21,10 +21,8 @@ import contextlib
from collections.abc import AsyncIterator, Sequence
from typing import IO, Any
-from deprecated import deprecated
from google.cloud.dataflow_v1beta3 import ListJobsRequest
-from airflow.exceptions import AirflowProviderDeprecationWarning
from airflow.providers.apache.beam.hooks.beam import BeamAsyncHook
from airflow.providers.google.cloud.hooks.dataflow import AsyncDataflowHook
from airflow.providers.google.cloud.hooks.gcs import GCSHook
@@ -289,20 +287,3 @@ class BeamJavaPipelineTrigger(BeamPipelineBaseTrigger):
else:
yield TriggerEvent({"status": "error", "message": "Operation
failed"})
return
-
-
-@deprecated(
- reason="`BeamPipelineTrigger` is deprecated. Please use
`BeamPythonPipelineTrigger`.",
- category=AirflowProviderDeprecationWarning,
-)
-class BeamPipelineTrigger(BeamPythonPipelineTrigger):
- """
- Trigger to perform checking the Python pipeline status until it reaches
terminate state.
-
- This class is deprecated. Please use
-
:class:`airflow.providers.apache.beam.triggers.beam.BeamPythonPipelineTrigger`
- instead.
- """
-
- def __init__(self, *args, **kwargs):
- super().__init__(*args, **kwargs)
