diff --git a/brickflow/codegen/databricks_bundle.py b/brickflow/codegen/databricks_bundle.py index 304d578..a48a72b 100644 --- a/brickflow/codegen/databricks_bundle.py +++ b/brickflow/codegen/databricks_bundle.py @@ -442,7 +442,7 @@ def adjust_file_path(self, file_path: str) -> str: ): bundle_files_local_path = "/".join( [ - "Workspace", + "/Workspace", self.project.bundle_base_path, self.project.bundle_obj_name, self.project.name, diff --git a/tests/codegen/expected_bundles/local_bundle.yml b/tests/codegen/expected_bundles/local_bundle.yml index d7635f8..9fb2620 100644 --- a/tests/codegen/expected_bundles/local_bundle.yml +++ b/tests/codegen/expected_bundles/local_bundle.yml @@ -243,7 +243,7 @@ "min_retry_interval_millis": null "retry_on_timeout": null "spark_python_task": - "python_file": "Workspace/Users/${workspace.current_user.userName}/.brickflow_bundles/test-project/local/files/spark/python/src/run_task.py" + "python_file": "/Workspace/Users/${workspace.current_user.userName}/.brickflow_bundles/test-project/local/files/spark/python/src/run_task.py" "source": "WORKSPACE" "parameters": - "--param1" diff --git a/tests/codegen/expected_bundles/local_bundle_prefix_suffix.yml b/tests/codegen/expected_bundles/local_bundle_prefix_suffix.yml index 7e72b28..66cecb1 100644 --- a/tests/codegen/expected_bundles/local_bundle_prefix_suffix.yml +++ b/tests/codegen/expected_bundles/local_bundle_prefix_suffix.yml @@ -123,7 +123,7 @@ targets: max_retries: null min_retry_interval_millis: null spark_python_task: - python_file: Workspace/Users/${workspace.current_user.userName}/.brickflow_bundles/test-project/local/files/spark/python/src/run_task.py + python_file: /Workspace/Users/${workspace.current_user.userName}/.brickflow_bundles/test-project/local/files/spark/python/src/run_task.py parameters: ["--param1", "World!", "all_tasks1", "test", "all_tasks3", "123"] source: WORKSPACE retry_on_timeout: null