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 9a1624b93d Rename `ExternalBranchPythonOperator` to
`BranchExternalPythonOperator` (#33360)
9a1624b93d is described below
commit 9a1624b93d97b3a62cee1efbe1c520699e1323ee
Author: Elad Kalif <[email protected]>
AuthorDate: Sun Aug 13 10:54:24 2023 +0300
Rename `ExternalBranchPythonOperator` to `BranchExternalPythonOperator`
(#33360)
---
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 0593b8de78..b0ec57033c 100644
--- a/airflow/operators/python.py
+++ b/airflow/operators/python.py
@@ -790,7 +790,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 0e9846c502..85c2dc976f 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,
@@ -1121,8 +1121,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):
