diff --git a/dbt/adapters/databricks/python_models/python_submissions.py b/dbt/adapters/databricks/python_models/python_submissions.py index 309c7124..50d5c94c 100644 --- a/dbt/adapters/databricks/python_models/python_submissions.py +++ b/dbt/adapters/databricks/python_models/python_submissions.py @@ -345,7 +345,7 @@ def build_submitter(self) -> PythonSubmitter: class PythonWorkflowConfigExtractor(PythonJobConfigExtractor): def __init__(self, parsed_model: Dict[str, Any]) -> None: super().__init__(parsed_model) - self.existing_job_id = self.job_config.pop("existing_job_id") + self.existing_job_id = self.job_config.pop("existing_job_id", "") self.workflow_name = self.job_config.get( "name", f"dbt__{self.database}-{self.schema}-{self.identifier}" ) diff --git a/tests/conftest.py b/tests/conftest.py index b8a0e077..a6b57211 100644 --- a/tests/conftest.py +++ b/tests/conftest.py @@ -7,7 +7,7 @@ def pytest_addoption(parser): - parser.addoption("--profile", action="store", default="databricks_uc_sql_endpoint", type=str) + parser.addoption("--profile", action="store", default="databricks_uc_cluster", type=str) # Using @pytest.mark.skip_profile('databricks_cluster') uses the 'skip_by_adapter_type'