'.'

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 (текущий запуск)"),

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("Обработка завершена успешно.")