File tree Expand file tree Collapse file tree 3 files changed +12
-1
lines changed Expand file tree Collapse file tree 3 files changed +12
-1
lines changed Original file line number Diff line number Diff line change 1
1
"""Library for leveraging the power of Sync"""
2
2
3
- __version__ = "1.8.0 "
3
+ __version__ = "1.8.1 "
4
4
5
5
TIME_FORMAT = "%Y-%m-%dT%H:%M:%SZ"
Original file line number Diff line number Diff line change 18
18
from sync .api import projects
19
19
from sync .clients .databricks import get_default_client
20
20
from sync .config import CONFIG # noqa F401
21
+ from sync .errors import DatabricksDBFSMissingFiles
21
22
from sync .models import (
22
23
DatabricksAPIError ,
23
24
DatabricksClusterReport ,
@@ -1459,6 +1460,10 @@ def _get_eventlog_from_dbfs(
1459
1460
1460
1461
prefix = format_dbfs_filepath (f"{ base_filepath } /eventlog/" )
1461
1462
root_dir = dbx_client .list_dbfs_directory (prefix )
1463
+
1464
+ if "files" not in root_dir :
1465
+ raise DatabricksDBFSMissingFiles ("Unable to locate files in DBFS dir - prefix:%s" , prefix )
1466
+
1462
1467
eventlog_files = [f for f in root_dir ["files" ] if f ["is_dir" ]]
1463
1468
matching_subdirectory = None
1464
1469
Original file line number Diff line number Diff line change
1
+ class DatabricksDBFSMissingFiles (RuntimeError ):
2
+ def __init__ (
3
+ self ,
4
+ message ,
5
+ ):
6
+ super ().__init__ (message )
You can’t perform that action at this time.
0 commit comments