|
2 | 2 |
|
3 | 3 | import pytest |
4 | 4 |
|
5 | | -from airflow.models import DagBag |
6 | | -from airflow.utils import db |
7 | | -import logging |
| 5 | +# from airflow.models import DagBag |
| 6 | +# from airflow.utils import db |
| 7 | +# import logging |
8 | 8 | from ted_sws.data_manager.adapters.notice_repository import NoticeRepository |
9 | 9 | from ted_sws.mapping_suite_processor.services.conceptual_mapping_processor import \ |
10 | 10 | mapping_suite_processor_from_github_expand_and_load_package_in_mongo_db |
|
15 | 15 | MAPPING_SUITE_ID = "package_F03_test" |
16 | 16 | MAPPING_SUITE_ID_WITH_VERSION = "package_F03_test_v2.3.0" |
17 | 17 |
|
18 | | - |
19 | | -@pytest.fixture(scope="session") |
20 | | -def dag_bag(): |
21 | | - os.environ["AIRFLOW_HOME"] = str(AIRFLOW_DAG_FOLDER) |
22 | | - os.environ["AIRFLOW__CORE__LOAD_EXAMPLES"] = "False" |
23 | | - # Initialising the Airflow DB so that it works properly with the new AIRFLOW_HOME |
24 | | - logging.disable(logging.CRITICAL) |
25 | | - db.resetdb() |
26 | | - db.initdb() |
27 | | - logging.disable(logging.NOTSET) |
28 | | - dag_bag = DagBag(dag_folder=AIRFLOW_DAG_FOLDER, include_examples=False, |
29 | | - read_dags_from_db=False) |
30 | | - return dag_bag |
| 18 | +# |
| 19 | +# @pytest.fixture(scope="session") |
| 20 | +# def dag_bag(): |
| 21 | +# os.environ["AIRFLOW_HOME"] = str(AIRFLOW_DAG_FOLDER) |
| 22 | +# os.environ["AIRFLOW__CORE__LOAD_EXAMPLES"] = "False" |
| 23 | +# # Initialising the Airflow DB so that it works properly with the new AIRFLOW_HOME |
| 24 | +# logging.disable(logging.CRITICAL) |
| 25 | +# db.resetdb() |
| 26 | +# db.initdb() |
| 27 | +# logging.disable(logging.NOTSET) |
| 28 | +# dag_bag = DagBag(dag_folder=AIRFLOW_DAG_FOLDER, include_examples=False, |
| 29 | +# read_dags_from_db=False) |
| 30 | +# return dag_bag |
31 | 31 |
|
32 | 32 |
|
33 | 33 | @pytest.fixture |
|
0 commit comments