update to latest joblib

1 files changed, 2 insertions, 1 deletions

diff --git a/api.py b/api.py
index fe6e6f8..430e885 100644
--- a/api.py
+++ b/api.py
@@ -129,7 +129,8 @@ class Processor(joblib.worker.Worker):
                         if obj is not None:
                             obj_id = obj["api_id"]
                 except asyncpg.exceptions.DeadlockDetectedError:
-                    raise joblib.worker.JobFailed("deadlock")
+                    raise joblib.worker.JobFailed("deadlock",
+                                                  True)  # critical
 
                 logging.debug("record processed")
                 if obj_id: