Update _databricks_submission.py

xiaoyongzhu · xiaoyongzhu · commit cb71e193503e · 2022-10-25T02:22:56.000-07:00
diff --git a/feathr_project/feathr/spark_provider/_databricks_submission.py b/feathr_project/feathr/spark_provider/_databricks_submission.py
@@ -98,14 +98,14 @@ def upload_or_get_cloud_path(self, local_path_or_http_path: str):
                 logger.info("Uploading folder {}", local_path_or_http_path)
                 dest_paths = []
                 for item in Path(local_path_or_http_path).glob('**/*.conf'):
-                    cloud_dest_path = self.upload_local_file(item.resolve())
+                    cloud_dest_path = self._upload_local_file_to_workspace(item.resolve())
                     dest_paths.extend([cloud_dest_path])
                 cloud_dest_path = ','.join(dest_paths)
             else:
-                cloud_dest_path = self.upload_local_file(local_path_or_http_path)
+                cloud_dest_path = self._upload_local_file_to_workspace(local_path_or_http_path)
         return cloud_dest_path
 
-    def upload_local_file(self, local_path: str) -> str:
+    def _upload_local_file_to_workspace(self, local_path: str) -> str:
         """
         Supports transferring file from a local path to cloud working storage.
         """
