Skip to content
Snippets Groups Projects

Use WorkerConfiguration instead of WorkerRun.configuration

Merged Manon Blanco requested to merge use-worker-configuration into master
2 files
+ 39
5
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -166,9 +166,14 @@ class BaseWorker(object):
worker_run = self.request(
"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")
configuration_id = worker_run.get("configuration_id")
if configuration_id:
worker_configuration = self.request(
"RetrieveWorkerConfiguration", id=configuration_id
)
self.user_configuration = worker_configuration.get("configuration")
if self.user_configuration:
logger.info("Loaded user configuration from WorkerRun")
task_id = os.environ.get("PONOS_TASK")
paths = None
Loading