diff --git a/backend/src/app/worker.clj b/backend/src/app/worker.clj index f54a3add1d..6df88a902e 100644 --- a/backend/src/app/worker.clj +++ b/backend/src/app/worker.clj @@ -409,7 +409,9 @@ {:status :retry :task task :error cause}))))) (get-task [task-id] - (ex/try (db/get* pool :task {:id task-id}))) + (ex/try! + (some-> (db/get* pool :task {:id task-id}) + (decode-task-row)))) (run-task [task-id] (loop [task (get-task task-id)]