This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-7-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit e690f5c56158ce61f9b9183713529bbb8296d4de Author: Elad Kalif <[email protected]> AuthorDate: Sun Aug 13 10:54:24 2023 +0300 Rename `ExternalBranchPythonOperator` to `BranchExternalPythonOperator` (#33360) (cherry picked from commit 9a1624b93d97b3a62cee1efbe1c520699e1323ee) --- airflow/operators/python.py | 2 +- tests/operators/test_python.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/airflow/operators/python.py b/airflow/operators/python.py index 479fb600c4..36ae816509 100644 --- a/airflow/operators/python.py +++ b/airflow/operators/python.py @@ -778,7 +778,7 @@ class ExternalPythonOperator(_BasePythonVirtualenvOperator): return None -class ExternalBranchPythonOperator(ExternalPythonOperator, SkipMixin): +class BranchExternalPythonOperator(ExternalPythonOperator, SkipMixin): """ A workflow can "branch" or follow a path after the execution of this task, Extends ExternalPythonOperator, so expects to get Python: diff --git a/tests/operators/test_python.py b/tests/operators/test_python.py index 986f3ae510..69e68838e7 100644 --- a/tests/operators/test_python.py +++ b/tests/operators/test_python.py @@ -40,8 +40,8 @@ from airflow.models.baseoperator import BaseOperator from airflow.models.taskinstance import TaskInstance, clear_task_instances, set_current_context from airflow.operators.empty import EmptyOperator from airflow.operators.python import ( + BranchExternalPythonOperator, BranchPythonOperator, - ExternalBranchPythonOperator, ExternalPythonOperator, PythonOperator, PythonVirtualenvOperator, @@ -1108,8 +1108,8 @@ class TestExternalPythonOperator(BaseTestPythonVirtualenvOperator): task._read_result(path=mock.Mock()) -class TestExternalBranchPythonOperator(BaseTestPythonVirtualenvOperator): - opcls = ExternalBranchPythonOperator +class TestBranchExternalPythonOperator(BaseTestPythonVirtualenvOperator): + opcls = BranchExternalPythonOperator @pytest.fixture(autouse=True) def setup_tests(self):
