This is an automated email from the ASF dual-hosted git repository. potiuk pushed a commit to branch v1-10-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit b371a3a6aabf7c9a6f57435736d4da675dd45329 Author: Jarek Potiuk <[email protected]> AuthorDate: Sat Nov 14 10:00:17 2020 +0100 fixup! fixup! Selective tests - depends on files changed in the commit. (#11417) --- tests/contrib/sensors/test_hdfs_sensor.py | 4 ++-- tests/jobs/test_local_task_job.py | 2 +- tests/jobs/test_scheduler_job.py | 2 +- tests/sensors/test_hdfs_sensor.py | 2 +- tests/task/task_runner/test_standard_task_runner.py | 2 +- 5 files changed, 6 insertions(+), 6 deletions(-) diff --git a/tests/contrib/sensors/test_hdfs_sensor.py b/tests/contrib/sensors/test_hdfs_sensor.py index 7de01d4..1655aa5 100644 --- a/tests/contrib/sensors/test_hdfs_sensor.py +++ b/tests/contrib/sensors/test_hdfs_sensor.py @@ -28,7 +28,7 @@ from airflow.exceptions import AirflowSensorTimeout class HdfsSensorFolderTests(unittest.TestCase): def setUp(self): - from tests.test_core import FakeHDFSHook + from tests.core.test_core import FakeHDFSHook self.hook = FakeHDFSHook self.log = logging.getLogger() self.log.setLevel(logging.DEBUG) @@ -124,7 +124,7 @@ class HdfsSensorFolderTests(unittest.TestCase): class HdfsSensorRegexTests(unittest.TestCase): def setUp(self): - from tests.test_core import FakeHDFSHook + from tests.core.test_core import FakeHDFSHook self.hook = FakeHDFSHook self.log = logging.getLogger() self.log.setLevel(logging.DEBUG) diff --git a/tests/jobs/test_local_task_job.py b/tests/jobs/test_local_task_job.py index 72e3628..26ee3b8 100644 --- a/tests/jobs/test_local_task_job.py +++ b/tests/jobs/test_local_task_job.py @@ -35,8 +35,8 @@ from airflow.utils.db import create_session from airflow.utils.net import get_hostname from airflow.utils.state import State from tests.compat import patch -from tests.test_core import TEST_DAG_FOLDER from airflow.utils.timeout import timeout +from tests.core.test_core import TEST_DAG_FOLDER from tests.test_utils.db import clear_db_runs from tests.test_utils.mock_executor import MockExecutor diff --git a/tests/jobs/test_scheduler_job.py b/tests/jobs/test_scheduler_job.py index f17939a..e705067 100644 --- a/tests/jobs/test_scheduler_job.py +++ b/tests/jobs/test_scheduler_job.py @@ -55,7 +55,7 @@ from airflow.utils.dates import days_ago from airflow.utils.db import create_session, provide_session from airflow.utils.state import State from tests.compat import MagicMock, Mock, PropertyMock, mock, patch -from tests.test_core import TEST_DAG_FOLDER +from tests.core.test_core import TEST_DAG_FOLDER from tests.test_utils.config import conf_vars from tests.test_utils.db import ( clear_db_dags, clear_db_errors, clear_db_pools, clear_db_runs, clear_db_sla_miss, set_default_pool_slots, diff --git a/tests/sensors/test_hdfs_sensor.py b/tests/sensors/test_hdfs_sensor.py index 6a71236..32dc3b6 100644 --- a/tests/sensors/test_hdfs_sensor.py +++ b/tests/sensors/test_hdfs_sensor.py @@ -23,7 +23,7 @@ from datetime import timedelta from airflow.exceptions import AirflowSensorTimeout from airflow.sensors.hdfs_sensor import HdfsSensor from airflow.utils.timezone import datetime -from tests.test_core import FakeHDFSHook +from tests.core.test_core import FakeHDFSHook DEFAULT_DATE = datetime(2015, 1, 1) TEST_DAG_ID = 'unit_test_dag' diff --git a/tests/task/task_runner/test_standard_task_runner.py b/tests/task/task_runner/test_standard_task_runner.py index e3fceec..dd2ce13 100644 --- a/tests/task/task_runner/test_standard_task_runner.py +++ b/tests/task/task_runner/test_standard_task_runner.py @@ -32,7 +32,7 @@ from airflow.utils.state import State from logging.config import dictConfig -from tests.test_core import TEST_DAG_FOLDER +from tests.core.test_core import TEST_DAG_FOLDER from tests.test_utils.db import clear_db_runs DEFAULT_DATE = timezone.datetime(2016, 1, 1)
