From 2149b76f630bd5e98c0518eab2b5f317c546b203 Mon Sep 17 00:00:00 2001
From: allegroai <>
Date: Tue, 3 Jan 2023 12:13:48 +0200
Subject: [PATCH] Fix crash when starting pipeline

---
 apiserver/services/pipelines.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/apiserver/services/pipelines.py b/apiserver/services/pipelines.py
index 76d2657..ab10a69 100644
--- a/apiserver/services/pipelines.py
+++ b/apiserver/services/pipelines.py
@@ -60,6 +60,7 @@ def start_pipeline(call: APICall, company_id: str, request: StartPipelineRequest
     queued, res = enqueue_task(
         task_id=task.id,
         company_id=company_id,
+        user_id=call.identity.user,
         queue_id=request.queue,
         status_message="Starting pipeline",
         status_reason="",