Commit 08c25ab5 authored by Markus Scheidgen's avatar Markus Scheidgen
Browse files

Made sure to propagate worker host correctly

parent d6ace338
Pipeline #45191 passed with stages
in 25 minutes and 29 seconds
......@@ -91,7 +91,7 @@ celery = CeleryConfig(
max_memory=int(os.environ.get('NOMAD_CELERY_MAXMEMORY', 64e6)), # 64 GB
timeout=int(os.environ.get('NOMAD_CELERY_TIMEOUT', 3 * 3600)), # 3h
acks_late=bool(os.environ.get('NOMAD_CELERY_ACKS_LATE', True)),
routing=os.environ.get('NOMAD_CELEREY_ROUTING', CELERY_QUEUE_ROUTING)
routing=os.environ.get('NOMAD_CELERY_ROUTING', CELERY_QUEUE_ROUTING)
)
fs = FSConfig(
tmp=os.environ.get('NOMAD_FILES_TMP_DIR', '.volumes/fs/tmp'),
......
......@@ -88,6 +88,7 @@ class Calc(Proc):
def upload(self) -> 'Upload':
if not self._upload:
self._upload = Upload.get(self.upload_id)
self._upload.worker_hostname = self.worker_hostname
return self._upload
@property
......
Markdown is supported
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