Skip to content
Snippets Groups Projects

Retrieve WorkerRun configuration on initialization

Merged Erwan Rouchet requested to merge worker-run-config into master
All threads resolved!
1 file
+ 2
0
Compare changes
  • Side-by-side
  • Inline
@@ -167,6 +167,8 @@ class BaseWorker(object):
"RetrieveWorkerRun", id=os.environ["ARKINDEX_WORKER_RUN_ID"]
)
self.user_configuration = worker_run.get("configuration")
if self.user_configuration:
logger.info("Loaded user configuration from WorkerRun")
task_id = os.environ.get("PONOS_TASK")
paths = None
Loading