Skip to content
9 changes: 0 additions & 9 deletions airflow-core/tests/conftest.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@
from contextlib import contextmanager
from pathlib import Path
from typing import TYPE_CHECKING
from unittest import mock

import pytest

Expand Down Expand Up @@ -126,14 +125,6 @@ def test_zip_path(tmp_path: Path):
return os.fspath(zipped)


@pytest.fixture
def mock_supervisor_comms():
with mock.patch(
"airflow.sdk.execution_time.task_runner.SUPERVISOR_COMMS", create=True
) as supervisor_comms:
yield supervisor_comms


if TYPE_CHECKING:
# Static checkers do not know about pytest fixtures' types and return,
# In case if them distributed through third party packages.
Expand Down
8 changes: 0 additions & 8 deletions airflow-core/tests/unit/hooks/test_base.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,6 @@
from tests_common.test_utils.config import conf_vars


@pytest.fixture
def mock_supervisor_comms():
with mock.patch(
"airflow.sdk.execution_time.task_runner.SUPERVISOR_COMMS", create=True
) as supervisor_comms:
yield supervisor_comms


class TestBaseHook:
def test_hook_has_default_logger_name(self):
hook = BaseHook()
Expand Down
8 changes: 0 additions & 8 deletions airflow-core/tests/unit/models/test_taskinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -127,14 +127,6 @@ def wrapper(ti):
return wrapper


@pytest.fixture
def mock_supervisor_comms():
with mock.patch(
"airflow.sdk.execution_time.task_runner.SUPERVISOR_COMMS", create=True
) as supervisor_comms:
yield supervisor_comms


class CallbackWrapper:
task_id: str | None = None
dag_id: str | None = None
Expand Down