Commit c6e4ce75 authored by Markus Scheidgen's avatar Markus Scheidgen
Browse files

Fixed multiple cleanup calls in upload processing, again.

parent 231fd649
Pipeline #52517 passed with stages
in 29 minutes and 43 seconds
......@@ -809,7 +809,7 @@ class Upload(Proc):
if not self.process_running and processed_calcs >= total_calcs:
# this can easily be called multiple times, e.g. upload finished after all calcs finished
modified_upload = self._get_collection().update(
dict(_id=self.upload_id, joined=False),
dict(_id=self.upload_id, joined__ne=True),
{'$set': {'joined': True}}, upsert=False)
if modified_upload is not None:
self.get_logger().debug('join')
......
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