Commit 98c1f0e7 authored by Markus Scheidgen's avatar Markus Scheidgen
Browse files

Use the right hostname for reprocessing calcs.

parent 254aa6ba
Pipeline #53773 passed with stages
in 19 minutes and 52 seconds
......@@ -187,7 +187,7 @@ class Proc(Document, metaclass=ProcMetaclass):
return self
def reset(self):
def reset(self, worker_hostname: str = None):
""" Resets the task chain. Assumes there no current running process. """
assert not self.process_running
......@@ -195,7 +195,7 @@ class Proc(Document, metaclass=ProcMetaclass):
self.tasks_status = PENDING
self.errors = []
self.warnings = []
self.worker_hostname = None
self.worker_hostname = worker_hostname
@classmethod
def get_by_id(cls, id: str, id_field: str):
......
......@@ -658,7 +658,7 @@ class Upload(Proc):
continue
calc.reset()
calc.reset(worker_hostname=self.worker_hostname)
parser = match_parser(calc.mainfile, staging_upload_files)
if parser is None:
......
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