diff --git a/coordinator/processor_environment.py b/coordinator/processor_environment.py
index 033d1c6e8adf351b46d402461a63f006e07e5bb9..ffcb8dfa9e4eda7d58be0a100f6661ffbfcc19af 100644
--- a/coordinator/processor_environment.py
+++ b/coordinator/processor_environment.py
@@ -16,7 +16,7 @@ from coordinator.processor_base import ProcessorBase
 from 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 met_processing.common.params_file_parser import ParamsFileParser
+from ews.met_processing.common.params_file_parser import ParamsFileParser
 
 
 logger = logging.getLogger(__name__)
@@ -154,7 +154,9 @@ class ProcessorEnvironment(ProcessorBase):
         '''Run post processing with the :class:`met_processing.runner.common.job_runner` package.'''
 
         logger.info(f"Running post-processing.")
-        from met_processing.runner.common import job_runner
+        from ews.met_processing.runner.common import job_runner
+
+
         job_runner.run_post_processing(run_params, sys_params, processor_name)
         logger.info('Data post processing is completed')