Skip to content
Snippets Groups Projects

Blast worker version on publication endpoints

Merged Yoann Schneider requested to merge blast-worker-version into master
19 files
+ 41
182
Compare changes
  • Side-by-side
  • Inline
Files
19
@@ -126,11 +126,6 @@ class BaseWorker(object):
# through a ponos agent
self.task_id = os.environ.get("PONOS_TASK")
self.worker_version_id = os.environ.get("WORKER_VERSION_ID")
if not self.worker_version_id:
logger.warning(
"Missing WORKER_VERSION_ID environment variable, worker is in read-only mode"
)
self.worker_run_id = os.environ.get("ARKINDEX_WORKER_RUN_ID")
if not self.worker_run_id:
logger.warning(
@@ -159,13 +154,9 @@ class BaseWorker(object):
Whether or not the worker can publish data.
:returns: False when dev mode is enabled with the ``--dev`` CLI argument,
when no worker version ID is provided or when no worker run ID is provided
when no worker run ID is provided
"""
return (
self.args.dev
or self.worker_version_id is None
or self.worker_run_id is None
)
return self.args.dev or self.worker_run_id is None
def setup_api_client(self):
"""
@@ -228,6 +219,10 @@ class BaseWorker(object):
# Load worker version information
worker_version = worker_run["worker_version"]
# Store worker version id
self.worker_version_id = worker_version["id"]
self.worker_details = worker_version["worker"]
logger.info(
f"Loaded worker {self.worker_details['name']} revision {worker_version['revision']['hash'][0:7]} from API"
Loading