Commit 1e63505b authored by Markus Scheidgen's avatar Markus Scheidgen
Browse files

Fixed issue with unaquired lock in re-process cli command.

parent 91ceb8e3
Pipeline #52392 passed with stages
in 17 minutes and 23 seconds
......@@ -175,11 +175,12 @@ def re_process(ctx, uploads, parallel: int):
upload.block_until_complete(interval=.1)
logger.info('re-processing complete', upload_id=upload.upload_id)
state['completed_count'] += 1
print(' re-processed %s of %s uploads' % (state['completed_count'], uploads_count))
state['available_threads_count'] += 1
cv.notify()
with cv:
state['completed_count'] += 1
print(' re-processed %s of %s uploads' % (state['completed_count'], uploads_count))
state['available_threads_count'] += 1
cv.notify()
for upload in uploads:
with cv:
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment