diff --git a/.gitignore b/.gitignore index 7a39135705b83d12eb7aefb3e05f97ee6e6bd55c..77b5d43f5b3ecc4957aa9341c15b290a406493d6 100644 --- a/.gitignore +++ b/.gitignore @@ -1,7 +1,7 @@ scratch* *.pyc *.zip -coordinator/logs/* +ews/coordinator/logs/* logs/* *.log Cred-WRSIS-API.json diff --git a/coordinator/__init__.py b/ews/coordinator/__init__.py similarity index 100% rename from coordinator/__init__.py rename to ews/coordinator/__init__.py diff --git a/coordinator/processor_advisory.py b/ews/coordinator/processor_advisory.py similarity index 94% rename from coordinator/processor_advisory.py rename to ews/coordinator/processor_advisory.py index b0e7f8b5dacd639fc17a22490bfa0cc4dea289e0..78aaa13e6110342e3eeeafe8f929f6a6d809f2a8 100644 --- a/coordinator/processor_advisory.py +++ b/ews/coordinator/processor_advisory.py @@ -5,8 +5,8 @@ import logging # gitlab projects # TODO: Package these projects so they are robust for importing -from coordinator.utils.processor_utils import short_name -from coordinator.processor_base import ProcessorBase +from ews.coordinator.utils.processor_utils import short_name +from ews.coordinator.processor_base import ProcessorBase from ews.advisory_builder import data_gatherer diff --git a/coordinator/processor_base.py b/ews/coordinator/processor_base.py similarity index 98% rename from coordinator/processor_base.py rename to ews/coordinator/processor_base.py index f099b95ca56bd15db6a6f1d7a7d6237ca396d275..4a93861633174669678ae436e5d7f5395e099248 100755 --- a/coordinator/processor_base.py +++ b/ews/coordinator/processor_base.py @@ -19,8 +19,8 @@ or:: from abc import abstractmethod, ABCMeta from typing import List -from coordinator.utils import processor_utils -from coordinator.utils.processor_utils import short_name, open_and_check_config, end_script, end_job, append_item_to_list, \ +from ews.coordinator.utils import processor_utils +from ews.coordinator.utils.processor_utils import short_name, open_and_check_config, end_script, end_job, append_item_to_list, \ clear_up diff --git a/coordinator/processor_deposition.py b/ews/coordinator/processor_deposition.py similarity index 97% rename from coordinator/processor_deposition.py rename to ews/coordinator/processor_deposition.py index 06b382900e15683ce7c7473a50d07d3a02d64303..48602331bc41e6a7043ce0841bc0b7aa33f37cd7 100644 --- a/coordinator/processor_deposition.py +++ b/ews/coordinator/processor_deposition.py @@ -10,9 +10,9 @@ from string import Template import iris from iris.cube import CubeList -from coordinator.utils import processor_utils -from coordinator.utils.processor_utils import subprocess_and_log, get_only_existing_globs -from coordinator.processor_base import ProcessorBase +from ews.coordinator.utils import processor_utils +from ews.coordinator.utils.processor_utils import subprocess_and_log, get_only_existing_globs +from ews.coordinator.processor_base import ProcessorBase from ews.postprocessing.deposition.deposition_post_processor import DepositionPostProcessor logger = logging.getLogger(__name__) diff --git a/coordinator/processor_environment.py b/ews/coordinator/processor_environment.py similarity index 99% rename from coordinator/processor_environment.py rename to ews/coordinator/processor_environment.py index ffcb8dfa9e4eda7d58be0a100f6661ffbfcc19af..1708eeb2d1e4021af069a5835e9d4d7751d50798 100644 --- a/coordinator/processor_environment.py +++ b/ews/coordinator/processor_environment.py @@ -12,8 +12,8 @@ from pathlib import Path import pandas as pd # from coordinator.env_suit import env_suit_pipeline -from coordinator.processor_base import ProcessorBase -from coordinator.utils.processor_utils import get_only_existing_globs, get_input_data +from ews.coordinator.processor_base import ProcessorBase +from ews.coordinator.utils.processor_utils import get_only_existing_globs, get_input_data from ews.postprocessing.environmental_suitability.env_suit_post_processor import EnvSuitPostProcessor from ews.postprocessing.utils.disease_info import EnvSuitDiseaseInfo from ews.met_processing.common.params_file_parser import ParamsFileParser diff --git a/coordinator/processor_epidemiology.py b/ews/coordinator/processor_epidemiology.py similarity index 99% rename from coordinator/processor_epidemiology.py rename to ews/coordinator/processor_epidemiology.py index f638f598050285c4d5c9e780895eca5c1c6276c4..5418a4cd6aa985b6de53de0605113a70b930fa0b 100644 --- a/coordinator/processor_epidemiology.py +++ b/ews/coordinator/processor_epidemiology.py @@ -22,10 +22,10 @@ from EpiModel import ( # created by rs481 plotRaster ) from EpiModel.EpiPrep import prep -from coordinator.processor_base import ProcessorBase +from ews.coordinator.processor_base import ProcessorBase from ews.postprocessing.epi.epi_post_processor import EPIPostPostProcessor -from coordinator.utils.processor_utils import ( +from ews.coordinator.utils.processor_utils import ( calc_epi_date_range, open_and_check_config, get_only_existing_globs, diff --git a/coordinator/processor_scraper.py b/ews/coordinator/processor_scraper.py similarity index 100% rename from coordinator/processor_scraper.py rename to ews/coordinator/processor_scraper.py diff --git a/coordinator/processor_surveys.py b/ews/coordinator/processor_surveys.py similarity index 95% rename from coordinator/processor_surveys.py rename to ews/coordinator/processor_surveys.py index 0d0edd65937a0f65ca8da59a9066ca35850ac279..ffc2355b2da4ad777fad38405b38d251d76a6dd7 100644 --- a/coordinator/processor_surveys.py +++ b/ews/coordinator/processor_surveys.py @@ -34,15 +34,15 @@ from numpy import all as np_all from numpy import any as np_any from pandas import read_csv, concat -from coordinator.survey_servers.processor_surveys_odk import get_ODK_form_as_csv -from coordinator.survey_servers.processor_surveys_odk_sa import get_ODK_SA_form_as_csv -from coordinator.survey_servers.processor_surveys_odk_v2 import get_ODKv2_form_as_csv -from coordinator.survey_servers.processor_surveys_wrsis import get_WRSIS_form_as_csv -from coordinator.survey_servers.processor_surveys_wrt import get_WRT_form_as_csv -from coordinator.survey_servers.processor_surveys_kobotoolbox import get_kobotoolbox_form_as_csv -from coordinator.survey_servers.processor_surveys_new_odk import get_newODK_form_as_csv -from coordinator.survey_servers.processor_surveys_new_odk2 import get_newODK2_form_as_csv -from coordinator.processor_base import ProcessorBase +from ews.coordinator.survey_servers.processor_surveys_odk import get_ODK_form_as_csv +from ews.coordinator.survey_servers.processor_surveys_odk_sa import get_ODK_SA_form_as_csv +from ews.coordinator.survey_servers.processor_surveys_odk_v2 import get_ODKv2_form_as_csv +from ews.coordinator.survey_servers.processor_surveys_wrsis import get_WRSIS_form_as_csv +from ews.coordinator.survey_servers.processor_surveys_wrt import get_WRT_form_as_csv +from ews.coordinator.survey_servers.processor_surveys_kobotoolbox import get_kobotoolbox_form_as_csv +from ews.coordinator.survey_servers.processor_surveys_new_odk import get_newODK_form_as_csv +from ews.coordinator.survey_servers.processor_surveys_new_odk2 import get_newODK2_form_as_csv +from ews.coordinator.processor_base import ProcessorBase from ews.source_gen.clustering import run_case diff --git a/coordinator/survey_servers/__init__.py b/ews/coordinator/survey_servers/__init__.py similarity index 100% rename from coordinator/survey_servers/__init__.py rename to ews/coordinator/survey_servers/__init__.py diff --git a/coordinator/survey_servers/processor_survey_utils.py b/ews/coordinator/survey_servers/processor_survey_utils.py similarity index 100% rename from coordinator/survey_servers/processor_survey_utils.py rename to ews/coordinator/survey_servers/processor_survey_utils.py diff --git a/coordinator/survey_servers/processor_surveys_kobotoolbox.py b/ews/coordinator/survey_servers/processor_surveys_kobotoolbox.py similarity index 98% rename from coordinator/survey_servers/processor_surveys_kobotoolbox.py rename to ews/coordinator/survey_servers/processor_surveys_kobotoolbox.py index ae27616fa19317773c468a22724152b0c42cadfc..b9f96c58644665765a41fbe1b66044232dd18bc9 100644 --- a/coordinator/survey_servers/processor_surveys_kobotoolbox.py +++ b/ews/coordinator/survey_servers/processor_surveys_kobotoolbox.py @@ -11,8 +11,8 @@ import requests from shutil import copyfile from pandas import DataFrame -from coordinator.survey_servers.processor_survey_utils import parse_columns -from coordinator.utils.processor_utils import end_job +from ews.coordinator.survey_servers.processor_survey_utils import parse_columns +from ews.coordinator.utils.processor_utils import end_job logger = logging.getLogger(__name__) diff --git a/coordinator/survey_servers/processor_surveys_new_odk.py b/ews/coordinator/survey_servers/processor_surveys_new_odk.py similarity index 98% rename from coordinator/survey_servers/processor_surveys_new_odk.py rename to ews/coordinator/survey_servers/processor_surveys_new_odk.py index 9436dd6c8bc516de3d295bf45bc9f76cfcadf197..57468437f7791b938814c8353265469e94767227 100644 --- a/coordinator/survey_servers/processor_surveys_new_odk.py +++ b/ews/coordinator/survey_servers/processor_surveys_new_odk.py @@ -11,8 +11,8 @@ import requests from shutil import copyfile from pandas import DataFrame -from coordinator.survey_servers.processor_survey_utils import parse_columns -from coordinator.utils.processor_utils import end_job +from ews.coordinator.survey_servers.processor_survey_utils import parse_columns +from ews.coordinator.utils.processor_utils import end_job logger = logging.getLogger(__name__) diff --git a/coordinator/survey_servers/processor_surveys_new_odk2.py b/ews/coordinator/survey_servers/processor_surveys_new_odk2.py similarity index 98% rename from coordinator/survey_servers/processor_surveys_new_odk2.py rename to ews/coordinator/survey_servers/processor_surveys_new_odk2.py index 5e4bdee9836d1a8fb753f1383c29b98e90409064..c5b6ea42016f695a2f204cba2998476eb74d3602 100644 --- a/coordinator/survey_servers/processor_surveys_new_odk2.py +++ b/ews/coordinator/survey_servers/processor_surveys_new_odk2.py @@ -10,14 +10,14 @@ from shutil import copyfile import requests -from coordinator.survey_servers.processor_survey_utils import parse_columns -from coordinator.survey_servers.processor_surveys_new_odk import ( +from ews.coordinator.survey_servers.processor_survey_utils import parse_columns +from ews.coordinator.survey_servers.processor_surveys_new_odk import ( cases_incident, cases_severity, get_from_kobotoolbox, build_dataframe ) -from coordinator.utils.processor_utils import end_job +from ews.coordinator.utils.processor_utils import end_job logger = logging.getLogger(__name__) diff --git a/coordinator/survey_servers/processor_surveys_odk.py b/ews/coordinator/survey_servers/processor_surveys_odk.py similarity index 99% rename from coordinator/survey_servers/processor_surveys_odk.py rename to ews/coordinator/survey_servers/processor_surveys_odk.py index 34780f6a3b50f7a4b31a8a341c4261f619507d60..fcfe93ed3c194aafbd0a5a5862b69f0f6827712d 100644 --- a/coordinator/survey_servers/processor_surveys_odk.py +++ b/ews/coordinator/survey_servers/processor_surveys_odk.py @@ -9,7 +9,7 @@ from pathlib import Path from shutil import copyfile from string import Template -from coordinator.utils.processor_utils import ( +from ews.coordinator.utils.processor_utils import ( subprocess_and_log, end_job, ) diff --git a/coordinator/survey_servers/processor_surveys_odk_sa.py b/ews/coordinator/survey_servers/processor_surveys_odk_sa.py similarity index 98% rename from coordinator/survey_servers/processor_surveys_odk_sa.py rename to ews/coordinator/survey_servers/processor_surveys_odk_sa.py index a1ddc1c83de0342f5a689c90113ddc1e869c0f99..1e035af2ceed69e164bca59929dbdee191006fe6 100644 --- a/coordinator/survey_servers/processor_surveys_odk_sa.py +++ b/ews/coordinator/survey_servers/processor_surveys_odk_sa.py @@ -13,8 +13,8 @@ from string import Template from pandas import read_csv -from coordinator.survey_servers.processor_survey_utils import parse_columns -from coordinator.utils.processor_utils import subprocess_and_log, end_job +from ews.coordinator.survey_servers.processor_survey_utils import parse_columns +from ews.coordinator.utils.processor_utils import subprocess_and_log, end_job logger = logging.getLogger(__name__) diff --git a/coordinator/survey_servers/processor_surveys_odk_v2.py b/ews/coordinator/survey_servers/processor_surveys_odk_v2.py similarity index 99% rename from coordinator/survey_servers/processor_surveys_odk_v2.py rename to ews/coordinator/survey_servers/processor_surveys_odk_v2.py index 3c381a6d3f7f055b1c87174c9ca834dffd80a4c3..8c7fd3b21d18616938ae78273631997cfa1a268c 100644 --- a/coordinator/survey_servers/processor_surveys_odk_v2.py +++ b/ews/coordinator/survey_servers/processor_surveys_odk_v2.py @@ -14,8 +14,8 @@ from pathlib import Path from pandas import read_csv from shutil import copyfile -from coordinator.survey_servers.processor_survey_utils import parse_columns -from coordinator.utils.processor_utils import end_job +from ews.coordinator.survey_servers.processor_survey_utils import parse_columns +from ews.coordinator.utils.processor_utils import end_job logger = logging.getLogger(__name__) diff --git a/coordinator/survey_servers/processor_surveys_wrsis.py b/ews/coordinator/survey_servers/processor_surveys_wrsis.py similarity index 99% rename from coordinator/survey_servers/processor_surveys_wrsis.py rename to ews/coordinator/survey_servers/processor_surveys_wrsis.py index 9ac2cb817f489d1b19b49cb61138f972d3af032c..9411ac26b57ff419f2e3cdeb2d607e9fe8257179 100644 --- a/coordinator/survey_servers/processor_surveys_wrsis.py +++ b/ews/coordinator/survey_servers/processor_surveys_wrsis.py @@ -11,8 +11,8 @@ import requests from shutil import copyfile from pandas import json_normalize -from coordinator.survey_servers.processor_survey_utils import parse_columns -from coordinator.utils.processor_utils import end_job +from ews.coordinator.survey_servers.processor_survey_utils import parse_columns +from ews.coordinator.utils.processor_utils import end_job logger = logging.getLogger(__name__) diff --git a/coordinator/survey_servers/processor_surveys_wrt.py b/ews/coordinator/survey_servers/processor_surveys_wrt.py similarity index 98% rename from coordinator/survey_servers/processor_surveys_wrt.py rename to ews/coordinator/survey_servers/processor_surveys_wrt.py index 81c923e5c2633c115e4c2a6a452f6776144ebdb6..cbf553b5a49160ad40238bc8018890ec6a6f7b33 100644 --- a/coordinator/survey_servers/processor_surveys_wrt.py +++ b/ews/coordinator/survey_servers/processor_surveys_wrt.py @@ -11,8 +11,8 @@ import requests from shutil import copyfile from pandas import json_normalize -from coordinator.survey_servers.processor_survey_utils import parse_columns -from coordinator.utils.processor_utils import end_job +from ews.coordinator.survey_servers.processor_survey_utils import parse_columns +from ews.coordinator.utils.processor_utils import end_job logger = logging.getLogger(__name__) diff --git a/coordinator/utils/__init__.py b/ews/coordinator/utils/__init__.py similarity index 100% rename from coordinator/utils/__init__.py rename to ews/coordinator/utils/__init__.py diff --git a/coordinator/utils/buffering_smtp_handler.py b/ews/coordinator/utils/buffering_smtp_handler.py similarity index 100% rename from coordinator/utils/buffering_smtp_handler.py rename to ews/coordinator/utils/buffering_smtp_handler.py diff --git a/coordinator/utils/processor_utils.py b/ews/coordinator/utils/processor_utils.py similarity index 99% rename from coordinator/utils/processor_utils.py rename to ews/coordinator/utils/processor_utils.py index acdaadb879b5084ab563fe95ca7730aa95185dd1..4d7815f1fe977c995ff107df8652d3fdb9feaeb8 100644 --- a/coordinator/utils/processor_utils.py +++ b/ews/coordinator/utils/processor_utils.py @@ -15,10 +15,6 @@ import subprocess import sys import tarfile from typing import List -import netCDF4 as nc -import numpy as np -import pandas as pd -import cf_units from iris import load from iris.cube import CubeList @@ -356,7 +352,9 @@ def setup_logging(job_file_path: str, is_live: bool, log_level: str): # if there is no value set for the LOGGING_CONFIG file, set a default path. if not 'LOGGING_CONFIG' in os.environ: - import coordinator + from ews import coordinator + + log_config_path_project = os.path.join(os.path.dirname(coordinator.__file__), "..", "configs", "logger", "template_log_config.json") print(f"ENVIRONMENT VARIABLE 'LOGGING_CONFIG' IS NOT SET, UISING DEFAULT FILE - {log_config_path_project}") else: diff --git a/tests/integration/full/full_test_advisory.py b/tests/integration/full/full_test_advisory.py index 2337747b37da521be2735275914b855c988cb9f7..a4f989b9141c80d9181b9f5881283d9f176b4b2d 100644 --- a/tests/integration/full/full_test_advisory.py +++ b/tests/integration/full/full_test_advisory.py @@ -2,10 +2,10 @@ import copy import os import sys -from coordinator.processor_advisory import ProcessorAdvisory -from coordinator.processor_deposition import ProcessorDeposition -from coordinator.processor_environment import ProcessorEnvironment -from coordinator.processor_surveys import ProcessorSurveys +from ews.coordinator import ProcessorAdvisory +from ews.coordinator import ProcessorDeposition +from ews.coordinator import ProcessorEnvironment +from ews.coordinator.processor_surveys import ProcessorSurveys from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.advisory_test_suite import BaseAdvisoryTestSuite diff --git a/tests/integration/full/full_test_deposition.py b/tests/integration/full/full_test_deposition.py index c07e3af3a64a1e7fae4b8ec09ae369fec850f6ac..990d494c86719919c6a1d227e7d0ef20f40a337b 100644 --- a/tests/integration/full/full_test_deposition.py +++ b/tests/integration/full/full_test_deposition.py @@ -2,7 +2,7 @@ import copy import os import sys -from coordinator.processor_deposition import ProcessorDeposition +from ews.coordinator import ProcessorDeposition from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.depo_test_suite import BaseDepoTestSuite diff --git a/tests/integration/full/full_test_env_suit.py b/tests/integration/full/full_test_env_suit.py index 8d1989fbe68216f1785cf8c9c689b6075ef32149..3a70b2d2d273406180f2930e1084cc2a81406385 100644 --- a/tests/integration/full/full_test_env_suit.py +++ b/tests/integration/full/full_test_env_suit.py @@ -2,7 +2,7 @@ import copy import os import sys -from coordinator.processor_environment import ProcessorEnvironment +from ews.coordinator import ProcessorEnvironment from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.env_suit_test_suite import BaseEnvSuitTestSuite diff --git a/tests/integration/full/full_test_epi.py b/tests/integration/full/full_test_epi.py index 8027cde7fa769a73eafb0908f86cae334a95fc97..c690cccd439456c6b69f27fe8a95dbb991685980 100644 --- a/tests/integration/full/full_test_epi.py +++ b/tests/integration/full/full_test_epi.py @@ -2,9 +2,9 @@ import copy import os import sys -from coordinator.processor_deposition import ProcessorDeposition -from coordinator.processor_environment import ProcessorEnvironment -from coordinator.processor_epidemiology import ProcessorEpidemiology +from ews.coordinator import ProcessorDeposition +from ews.coordinator import ProcessorEnvironment +from ews.coordinator.processor_epidemiology import ProcessorEpidemiology from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.epi_test_suite import BaseEpiTestSuite diff --git a/tests/integration/full/full_test_survey.py b/tests/integration/full/full_test_survey.py index cff7c65ed0adb317bf930e212888ad8a13b90df1..b6c8ae6c38b3970b5e9ab3f0e1e5785ed681ec35 100644 --- a/tests/integration/full/full_test_survey.py +++ b/tests/integration/full/full_test_survey.py @@ -2,7 +2,7 @@ import copy import os import sys -from coordinator.processor_surveys import ProcessorSurveys +from ews.coordinator.processor_surveys import ProcessorSurveys from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.survey_test_suite import BaseSurveyTestSuite diff --git a/tests/integration/partial/integration_test_utils.py b/tests/integration/partial/integration_test_utils.py index c32955fc6b2a0a40690671d17014d7cfcab4c210..9a02b0ce0c9ca173721431b8030a0c1eb8845d04 100644 --- a/tests/integration/partial/integration_test_utils.py +++ b/tests/integration/partial/integration_test_utils.py @@ -4,13 +4,13 @@ import glob import json import os -from typing import List, Type +from typing import List from unittest import TestSuite, TestLoader, TestCase, TestResult from zipfile import ZipFile from HTMLTestRunner import HTMLTestRunner -from coordinator.processor_base import ProcessorBase +from ews.coordinator.processor_base import ProcessorBase class IntegrationTestUtils: diff --git a/tests/integration/partial/test_advisory.py b/tests/integration/partial/test_advisory.py index d0b01ce933d8e1f749ce5d4296bffa21e7184900..2ca6ef8ce0e155294d458783a5f3714a952fa983 100644 --- a/tests/integration/partial/test_advisory.py +++ b/tests/integration/partial/test_advisory.py @@ -2,7 +2,7 @@ import copy import os import unittest -from coordinator.processor_advisory import ProcessorAdvisory +from ews.coordinator.processor_advisory import ProcessorAdvisory from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.advisory_test_suite import BaseAdvisoryTestSuite diff --git a/tests/integration/partial/test_deposition.py b/tests/integration/partial/test_deposition.py index 28cd5d44432fc1dda72ab72e68232541dabac985..f8f214c14737816bcb7834152d131cec44422c76 100644 --- a/tests/integration/partial/test_deposition.py +++ b/tests/integration/partial/test_deposition.py @@ -2,7 +2,7 @@ import copy import os import unittest -from coordinator.processor_deposition import ProcessorDeposition +from ews.coordinator.processor_deposition import ProcessorDeposition from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.depo_test_suite import BaseDepoTestSuite diff --git a/tests/integration/partial/test_env_suit.py b/tests/integration/partial/test_env_suit.py index 3ba428625302a21c662078babafb911fda968147..38bde21354d1812c7f9fab4c6750e0f68a5fcd69 100644 --- a/tests/integration/partial/test_env_suit.py +++ b/tests/integration/partial/test_env_suit.py @@ -2,7 +2,7 @@ import copy import os import unittest -from coordinator.processor_environment import ProcessorEnvironment +from ews.coordinator.processor_environment import ProcessorEnvironment from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.env_suit_test_suite import BaseEnvSuitTestSuite diff --git a/tests/integration/partial/test_epi.py b/tests/integration/partial/test_epi.py index d2ec40ad4b15bd678e385b6fef0ce4b29e8c6b02..65837610098004fbd666f1cbfac8cbef9deeebbd 100644 --- a/tests/integration/partial/test_epi.py +++ b/tests/integration/partial/test_epi.py @@ -2,7 +2,7 @@ import copy import os import unittest -from coordinator.processor_epidemiology import ProcessorEpidemiology +from ews.coordinator.processor_epidemiology import ProcessorEpidemiology from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.epi_test_suite import BaseEpiTestSuite diff --git a/tests/integration/partial/test_survey.py b/tests/integration/partial/test_survey.py index 2a48e16354c833fa1a12a37e210c117b2f8e991a..0d7c2f881b3e27d97d6fe13e51d1bb4bdc212f62 100644 --- a/tests/integration/partial/test_survey.py +++ b/tests/integration/partial/test_survey.py @@ -2,7 +2,7 @@ import copy import os import unittest -from coordinator.processor_surveys import ProcessorSurveys +from ews.coordinator.processor_surveys import ProcessorSurveys from integration.partial.integration_test_utils import IntegrationTestUtils from integration.test_suites.survey_test_suite import BaseSurveyTestSuite