diff --git a/import-automation/executor/app/executor/import_executor.py b/import-automation/executor/app/executor/import_executor.py
index 0b7b9bf01..d18054d43 100644
--- a/import-automation/executor/app/executor/import_executor.py
+++ b/import-automation/executor/app/executor/import_executor.py
@@ -564,6 +564,7 @@ def _run_with_timeout_async(args: List[str],
             stdout.append(line)
             logging.info(f'Process stdout: {line}')
 
+        process.wait()
         end_time = time.time()
 
         return_code = process.returncode