use ARKINDEX_WORKER_RUN_ID

arkindex_worker/worker/base.py

@@ -110,10 +110,10 @@ class BaseWorker(object):
             logger.warning(
                 "Missing WORKER_VERSION_ID environment variable, worker is in read-only mode"
             )
-        self.worker_run_id = os.environ.get("WORKER_RUN_ID")
+        self.worker_run_id = os.environ.get("ARKINDEX_WORKER_RUN_ID")
         if not self.worker_run_id:
             logger.warning(
-                "Missing WORKER_RUN_ID environment variable, worker is in read-only mode"
+                "Missing ARKINDEX_WORKER_RUN_ID environment variable, worker is in read-only mode"
             )
 
         logger.info(f"Worker will use {self.work_dir} as working directory")

tests/conftest.py

@@ -104,7 +104,7 @@ def setup_api(responses, monkeypatch, cache_yaml):
 def give_env_variable(request, monkeypatch):
     """Defines required environment variables"""
     monkeypatch.setenv("WORKER_VERSION_ID", "12341234-1234-1234-1234-123412341234")
-    monkeypatch.setenv("WORKER_RUN_ID", "56785678-5678-5678-5678-567856785678")
+    monkeypatch.setenv("ARKINDEX_WORKER_RUN_ID", "56785678-5678-5678-5678-567856785678")
     monkeypatch.setenv("ARKINDEX_CORPUS_ID", "11111111-1111-1111-1111-111111111111")
 
 

tests/test_base_worker.py

@@ -49,7 +49,7 @@ def test_init_var_ponos_data_given(monkeypatch):
 def test_init_var_worker_version_id_missing(monkeypatch):
     monkeypatch.setattr(sys, "argv", ["worker"])
     monkeypatch.delenv("WORKER_VERSION_ID")
-    monkeypatch.delenv("WORKER_RUN_ID")
+    monkeypatch.delenv("ARKINDEX_WORKER_RUN_ID")
     worker = BaseWorker()
     worker.args = worker.parser.parse_args()
     worker.configure_for_developers()
@@ -60,7 +60,7 @@ def test_init_var_worker_version_id_missing(monkeypatch):
 
 def test_init_var_worker_run_id_missing(monkeypatch):
     monkeypatch.setattr(sys, "argv", ["worker"])
-    monkeypatch.delenv("WORKER_RUN_ID")
+    monkeypatch.delenv("ARKINDEX_WORKER_RUN_ID")
     worker = BaseWorker()
     worker.args = worker.parser.parse_args()
     worker.configure_for_developers()
@@ -76,7 +76,7 @@ def test_init_var_worker_local_file(monkeypatch, tmp_path):
 
     monkeypatch.setattr(sys, "argv", ["worker", "-c", str(config)])
     monkeypatch.delenv("WORKER_VERSION_ID")
-    monkeypatch.delenv("WORKER_RUN_ID")
+    monkeypatch.delenv("ARKINDEX_WORKER_RUN_ID")
     worker = BaseWorker()
     worker.args = worker.parser.parse_args()
     worker.configure_for_developers()