File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -224,8 +224,8 @@ def create_catalog(self, relation):
224
224
database = relation .database
225
225
schema = relation .schema
226
226
227
- if database == ("@" + credentials .UID ) or self .__catalog_exists (
228
- [ database ] ):
227
+ if database == ("@" + credentials .UID ) or self ._catalog_exists (
228
+ database ):
229
229
logger .debug (
230
230
"Database is default or already exists: creating folders only" )
231
231
else :
@@ -237,14 +237,14 @@ def create_catalog(self, relation):
237
237
self ._create_folders (database , schema , rest_client )
238
238
return
239
239
240
- def __catalog_exists (self , path ):
240
+ def _catalog_exists (self , path : str ):
241
241
thread_connection = self .get_thread_connection ()
242
242
connection = self .open (thread_connection )
243
243
rest_client = connection .handle .get_client ()
244
244
try :
245
245
catalog_info = rest_client .get_catalog_item (
246
246
catalog_id = None ,
247
- catalog_path = path ,
247
+ catalog_path = [ path ] ,
248
248
)
249
249
return catalog_info .get ("id" ) is not None
250
250
except DremioNotFoundException :
You can’t perform that action at this time.
0 commit comments