Depend only on RetrieveWorkerRun to get all the informations needed

Closes #115 (closed)

arkindex_worker/worker/base.py

@@ -85,7 +85,6 @@ class BaseWorker(object):
             help=(
                 "Run worker in developer mode. "
                 "Worker will be in read-only state even if a worker_version is supplied. "
-                "ARKINDEX_PROCESS_ID environment variable is not required with this flag."
             ),
             action="store_true",
             default=False,
@@ -185,11 +184,14 @@ class BaseWorker(object):
         # Load process information
         self.process_information = worker_run["process"]
 
-        # Retrieve initial configuration from API
+        # Load worker version information
         worker_version = worker_run["worker_version"]
+        self.worker_details = worker_version["worker"]
         logger.info(
-            f"Loaded worker {worker_version['worker']['name']} revision {worker_version['revision']['hash'][0:7]} from API"
+            f"Loaded worker {self.worker_details['name']} revision {worker_version['revision']['hash'][0:7]} from API"
         )
+
+        # Retrieve initial configuration from API
         self.config = worker_version["configuration"]["configuration"]
         if "user_configuration" in worker_version["configuration"]:
             # Add default values (if set) to user_configuration
@@ -198,10 +200,9 @@ class BaseWorker(object):
             ].items():
                 if "default" in value:
                     self.user_configuration[key] = value["default"]
-        self.worker_details = worker_version["worker"]
-        required_secrets = worker_version["configuration"].get("secrets", [])
 
         # Load all required secrets
+        required_secrets = worker_version["configuration"].get("secrets", [])
         self.secrets = {name: self.load_secret(name) for name in required_secrets}
 
         # Load worker run configuration when available
@@ -209,11 +210,10 @@ class BaseWorker(object):
         self.user_configuration = worker_configuration.get("configuration")
         if self.user_configuration:
             logger.info("Loaded user configuration from WorkerRun")
-
-        # if debug mode is set to true activate debug mode in logger
-        if self.user_configuration and self.user_configuration.get("debug"):
-            logger.setLevel(logging.DEBUG)
-            logger.debug("Debug output enabled")
+            # if debug mode is set to true activate debug mode in logger
+            if self.user_configuration.get("debug"):
+                logger.setLevel(logging.DEBUG)
+                logger.debug("Debug output enabled")
 
     def configure_cache(self):
         task_id = os.environ.get("PONOS_TASK")