diff --git a/app/pipeline/service.py b/app/pipeline/service.py index 2340e45..e65495a 100644 --- a/app/pipeline/service.py +++ b/app/pipeline/service.py @@ -50,6 +50,7 @@ def run_batch( samba_user: str, samba_password: str, launcher: str, + artifacts_dir: str | None = None, ) -> BatchResult: started_at = time.perf_counter() messages: list[str] = [] @@ -84,7 +85,8 @@ def run_batch( messages=[access_error or "Ошибка доступа к входной папке."], ) - run_context = create_run_context(input_dir=input_dir, samba_conn=samba_conn) + workspace_dir = artifacts_dir or input_dir + run_context = create_run_context(input_dir=workspace_dir, samba_conn=samba_conn) checks = [ (input_dir, "Входная папка (перемещение файлов)"), (run_context.run_dir, "Папка Out (текущий запуск)"), diff --git a/main.py b/main.py index e4b8b0e..76f57a2 100644 --- a/main.py +++ b/main.py @@ -79,6 +79,7 @@ def main() -> None: samba_user=samba_user, samba_password=samba_password, launcher=launcher_name, + artifacts_dir=resolved_input_dir, ) if batch_result.status == "success": st.success("Обработка завершена успешно.")