diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-09 18:53:08 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-09 18:53:08 +0100 |
| commit | 906958d6bf575745801189af3a4da6652eceee8d (patch) | |
| tree | 747c74fc59584f13862a6900917789cc7f231bf5 | |
| parent | d8c18eb6c25db3b802207b292e3e157741ac5bc9 (diff) | |
| download | processor-906958d6bf575745801189af3a4da6652eceee8d.tar.gz processor-906958d6bf575745801189af3a4da6652eceee8d.zip | |
update to latest joblib
| -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 |
