diff --git a/datahub-actions/setup.py b/datahub-actions/setup.py
index 5b9ce7f8..6fffa70c 100644
--- a/datahub-actions/setup.py
+++ b/datahub-actions/setup.py
@@ -30,10 +30,10 @@ def get_long_description():
     return description
 
 
-acryl_datahub_min_version = os.environ.get("ACRYL_DATAHUB_MIN_VERSION") or "0.11.0"
+acryl_datahub_min_version = os.environ.get("ACRYL_DATAHUB_MIN_VERSION") or "0.12.1.2"
 
 base_requirements = {
-    f"acryl-datahub[kafka]>={acryl_datahub_min_version},<=0.12.1.2",
+    f"acryl-datahub[kafka]>={acryl_datahub_min_version}",
     # Compatibility.
     "typing_extensions>=3.7.4; python_version < '3.8'",
     "mypy_extensions>=0.4.3",
diff --git a/datahub-actions/src/datahub_actions/cli/actions.py b/datahub-actions/src/datahub_actions/cli/actions.py
index f56d2e5e..97efd41f 100644
--- a/datahub-actions/src/datahub_actions/cli/actions.py
+++ b/datahub-actions/src/datahub_actions/cli/actions.py
@@ -22,7 +22,11 @@
 
 import click
 from click_default_group import DefaultGroup
-from datahub.configuration.config_loader import _resolve_element, load_config_file
+from datahub.configuration.config_loader import (
+    Environ,
+    _resolve_element,
+    load_config_file,
+)
 
 import datahub_actions as datahub_actions_package
 from datahub_actions.pipeline.pipeline import Pipeline
@@ -35,9 +39,9 @@
 pipeline_manager = PipelineManager()
 
 
-def best_effort_resolve_element(x: str) -> str:
+def best_effort_resolve_element(x: str, environ: Environ) -> str:
     try:
-        return _resolve_element(x)
+        return _resolve_element(x, environ=environ)
     except Exception:
         return x