You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2020/11/14 09:02:04 UTC
[airflow] 07/07: fixup! fixup! Selective tests - depends on files
changed in the commit. (#11417)
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 <ja...@potiuk.com>
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)