diff --git a/arkindex_worker/worker/__init__.py b/arkindex_worker/worker/__init__.py index 12a59b44558740d08de7f4a2dab31bb0f1ed09a2..b7325d84b2c42657272955d2ca1b8fccf43fa10e 100644 --- a/arkindex_worker/worker/__init__.py +++ b/arkindex_worker/worker/__init__.py @@ -68,6 +68,7 @@ class ElementsWorker( def __init__(self, description="Arkindex Elements Worker", support_cache=False): super().__init__(description, support_cache) + # Add mandatory argument to process elements self.parser.add_argument( "--elements-list", diff --git a/arkindex_worker/worker/base.py b/arkindex_worker/worker/base.py index b25e2f56aee3dd6fb93d534428d56e404fd01fc2..1e63819edfd7314012a968517db94de6d41bd943 100644 --- a/arkindex_worker/worker/base.py +++ b/arkindex_worker/worker/base.py @@ -170,7 +170,7 @@ class BaseWorker(object): self.api_client = ArkindexClient(**options_from_env()) logger.debug(f"Setup Arkindex API client on {self.api_client.document.url}") - # Load process information except in developer mode + # Load process information assert os.environ.get( "ARKINDEX_PROCESS_ID" ), "ARKINDEX_PROCESS_ID environment variable is not defined" @@ -199,7 +199,7 @@ class BaseWorker(object): # Load all required secrets self.secrets = {name: self.load_secret(name) for name in required_secrets} - # Load worker run configuration when available and not in dev mode + # Load worker run configuration when available if os.environ.get("ARKINDEX_WORKER_RUN_ID"): worker_run = self.request( "RetrieveWorkerRun", id=os.environ["ARKINDEX_WORKER_RUN_ID"]