diff --git a/coordinator/processor_surveys.py b/coordinator/processor_surveys.py
index ce0d53f274d14d971d78a11536f6483b9e005466..0d0edd65937a0f65ca8da59a9066ca35850ac279 100644
--- a/coordinator/processor_surveys.py
+++ b/coordinator/processor_surveys.py
@@ -43,7 +43,7 @@ from coordinator.survey_servers.processor_surveys_kobotoolbox import get_kobotoo
 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 source_gen.clustering import run_case
+from ews.source_gen.clustering import run_case
 
 
 logger = logging.getLogger(__name__)