diff --git a/arkindex_worker/worker/__init__.py b/arkindex_worker/worker/__init__.py
index 5e888a00ef00d300ae94f67b1ae3ac0e64a2f020..af509a2bf62ca724567d65d2ee318ada2a98e425 100644
--- a/arkindex_worker/worker/__init__.py
+++ b/arkindex_worker/worker/__init__.py
@@ -212,10 +212,7 @@ class ElementsWorker(
                 element_id = element.id if element else item
 
                 if isinstance(e, ErrorResponse):
-                    if e.title == "404 Not Found":
-                        message = f"An API error occurred while processing element {element_id}: ARKINDEX_CORPUS_ID was not set in the environment"
-                    else:
-                        message = f"An API error occurred while processing element {element_id}: {e.title} - {e.content}"
+                    message = f"An API error occurred while processing element {element_id}: {e.title} - {e.content}"
                 else:
                     message = (
                         f"Failed running worker on element {element_id}: {repr(e)}"
diff --git a/arkindex_worker/worker/base.py b/arkindex_worker/worker/base.py
index c8bcc315b93ddf681f8cd30a0d77d2b6fcb808d0..474464c86f63f982070c8ffaa573e39bc5db8ed9 100644
--- a/arkindex_worker/worker/base.py
+++ b/arkindex_worker/worker/base.py
@@ -193,6 +193,10 @@ class BaseWorker(object):
 
         # Define corpus_id from environment
         self.corpus_id = os.environ.get("ARKINDEX_CORPUS_ID")
+        if not self.corpus_id:
+            logger.warning(
+                "'ARKINDEX_CORPUS_ID' was not set in the environment. Any API request involving a `corpus_id` will fail."
+            )
 
         # Load all required secrets
         self.secrets = {name: self.load_secret(name) for name in required_secrets}