diff --git a/python_modules/libraries/dagster-databricks/dagster_databricks/pipes.py b/python_modules/libraries/dagster-databricks/dagster_databricks/pipes.py index ec7e906ae20a2..a673c3bab78ba 100644 --- a/python_modules/libraries/dagster-databricks/dagster_databricks/pipes.py +++ b/python_modules/libraries/dagster-databricks/dagster_databricks/pipes.py @@ -474,7 +474,7 @@ def name(self) -> str: # job has finished. def _get_log_path(self, params: PipesParams) -> Optional[str]: if self.log_path is None: - cluster_driver_log_root = params["extras"].get("cluster_driver_log_root") + cluster_driver_log_root = params["extras"].get("cluster_driver_log_root") if "extras" in params else None if cluster_driver_log_root is None: return None try: