diff --git a/arkindex_worker/worker/base.py b/arkindex_worker/worker/base.py
index f892558e4254f9f0255ff036e62fc9557b2206c6..fe27e0d328b1614888d447761d3aeaad87a2ccdf 100644
--- a/arkindex_worker/worker/base.py
+++ b/arkindex_worker/worker/base.py
@@ -119,6 +119,8 @@ class BaseWorker(object):
         logger.info(f"Worker will use {self.work_dir} as working directory")
 
         self.process_information = None
+        # corpus_id will be updated in configure() using the worker_run's corpus
+        # or in configure_for_developers() from the environment
         self.corpus_id = None
         self.user_configuration = {}
         self.support_cache = support_cache
@@ -170,6 +172,9 @@ class BaseWorker(object):
             required_secrets = []
             logger.warning("Running without any extra configuration")
 
+        # Define corpus_id from environment
+        self.corpus_id = os.environ.get("ARKINDEX_CORPUS_ID")
+
         # Load all required secrets
         self.secrets = {name: self.load_secret(name) for name in required_secrets}