diff options
| -rw-r--r-- | api.py | 3 | ||||
| m--------- | joblib | 0 |
2 files changed, 2 insertions, 1 deletions
@@ -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: diff --git a/joblib b/joblib -Subproject 7fa00a9e4f2723f7d93fc1ecc8369ccbbc9e4f7 +Subproject 535a14f4ea1973eaabcaf4624604a42335b1598 |
