diff --git a/src/mpyl/steps/deploy/dagster.py b/src/mpyl/steps/deploy/dagster.py
index 56ca4ac22..a69db2423 100644
--- a/src/mpyl/steps/deploy/dagster.py
+++ b/src/mpyl/steps/deploy/dagster.py
@@ -68,7 +68,7 @@ def execute(self, step_input: Input) -> Output:
         properties = step_input.run_properties
         context = get_cluster_config_for_project(
             step_input.run_properties, step_input.project_execution.project
-        ).cluster_env
+        ).context
         dagster_config: DagsterConfig = DagsterConfig.from_dict(properties.config)
         dagster_deploy_results = []