Skip to content

Commit

Permalink
Removed deprecated code (apache#44700)
Browse files Browse the repository at this point in the history
  • Loading branch information
ajitg25 authored Dec 6, 2024
1 parent 258ef9d commit 7fde48d
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 19 deletions.
9 changes: 9 additions & 0 deletions providers/src/airflow/providers/apache/beam/CHANGELOG.rst
Original file line number Diff line number Diff line change
Expand Up @@ -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
.....

Expand Down
19 changes: 0 additions & 19 deletions providers/src/airflow/providers/apache/beam/triggers/beam.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,8 @@
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
Expand Down Expand Up @@ -289,20 +287,3 @@ async def run(self) -> AsyncIterator[TriggerEvent]: # type: ignore[override]
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)

0 comments on commit 7fde48d

Please sign in to comment.