diff --git a/arkindex_worker/worker/base.py b/arkindex_worker/worker/base.py
index c3a08f1d54ca5a98e86141a48311159478405c9f..78cbb8d61795de05a60e8c305413401f2a256c2b 100644
--- a/arkindex_worker/worker/base.py
+++ b/arkindex_worker/worker/base.py
@@ -145,7 +145,7 @@ class BaseWorker(object):
             merge_parents_cache(
                 task["parents"],
                 self.cache_path,
-                data_dir=os.environ.get("PONOS_DATA_DIR", "/data"),
+                data_dir=os.environ.get("PONOS_DATA", "/data"),
                 chunk=os.environ.get("ARKINDEX_TASK_CHUNK"),
             )
 
diff --git a/tests/test_merge.py b/tests/test_merge.py
index 344f067c9287626bd25b119443dc9607dbefece8..a2061622f38b6d6ce6ddec4c15e3d59173eac695 100644
--- a/tests/test_merge.py
+++ b/tests/test_merge.py
@@ -151,7 +151,7 @@ def test_merge_from_worker(
     assert CachedTranscription.select().count() == 0
 
     # Configure worker with a specific data directory
-    monkeypatch.setenv("PONOS_DATA_DIR", str(tmpdir))
+    monkeypatch.setenv("PONOS_DATA", str(tmpdir))
     mock_base_worker_with_cache.configure()
 
     # Then we have 2 elements and a transcription