If exception occures - set concurrency as available

This commit is contained in:
Eriks K 2020-12-17 18:02:14 +02:00
parent a09c37a065
commit 9646d112d2

View File

@ -397,7 +397,11 @@ def wait_for_lock(function):
return None return None
else: else:
instance.concurrency_available.clear() instance.concurrency_available.clear()
try:
ret = function(instance, *args, **kwargs) ret = function(instance, *args, **kwargs)
except Exception as e:
instance.concurrency_available.set()
raise e
instance.concurrency_available.set() instance.concurrency_available.set()
return ret return ret
return wrapper return wrapper