@@ -865,7 +865,11 @@ impl DatabricksAdapter {
865865 Ok ( ( ) )
866866 }
867867
868- async fn ensure_notebook ( & self , scenario_slug : & str , table_locations : & HashMap < String , String > ) -> Result < ( ) > {
868+ async fn ensure_notebook (
869+ & self ,
870+ scenario_slug : & str ,
871+ table_locations : & HashMap < String , String > ,
872+ ) -> Result < ( ) > {
869873 let table_locations_json = serde_json:: to_string ( table_locations) ?;
870874 let notebook_source = format ! (
871875 r#"
@@ -1041,9 +1045,7 @@ print("OK")
10411045 eprintln ! (
10421046 "[databricks-adapter] failed to create scheduled sync job: scenario={scenario_slug} job_name={job_name} status={status} body={body}"
10431047 ) ;
1044- return Err ( anyhow ! (
1045- "Databricks jobs/create failed ({status}): {body}"
1046- ) ) ;
1048+ return Err ( anyhow ! ( "Databricks jobs/create failed ({status}): {body}" ) ) ;
10471049 }
10481050
10491051 eprintln ! (
@@ -1350,17 +1352,17 @@ impl Handler for DatabricksAdapter {
13501352 ) ;
13511353 self . execute_sql_statement ( & drop_sql) . await . map_err ( |e| {
13521354 format ! (
1353- "Failed to drop existing Lakebase table '{table_name}' during create_tables: {e}"
1355+ "Failed to drop existing table '{table_name}' during create_tables: {e}"
13541356 )
13551357 } ) ?;
13561358
13571359 let create_sql = self . create_table_ctas ( table_name, location) ;
13581360
13591361 eprintln ! ( "[databricks-adapter] create_table '{table_name}': {create_sql}" ) ;
13601362
1361- self . execute_sql_statement ( & create_sql) . await . map_err ( |e| {
1362- format ! ( "Failed to create Lakebase table '{table_name}': {e}" )
1363- } ) ?;
1363+ self . execute_sql_statement ( & create_sql)
1364+ . await
1365+ . map_err ( |e| format ! ( "Failed to create table '{table_name}': {e}" ) ) ?;
13641366
13651367 table_locations. insert ( table_name. clone ( ) , location. to_string ( ) ) ;
13661368 created_tables. push ( table_name. clone ( ) ) ;
@@ -1377,8 +1379,8 @@ impl Handler for DatabricksAdapter {
13771379 . map_err ( |e| format ! ( "Failed to upload sync notebook: {e}" ) ) ?;
13781380
13791381 self . ensure_notebook_sync_job ( & scenario_slug)
1380- . await
1381- . map_err ( |e| format ! ( "Failed to create scheduled notebook sync job: {e}" ) ) ?;
1382+ . await
1383+ . map_err ( |e| format ! ( "Failed to create scheduled notebook sync job: {e}" ) ) ?;
13821384
13831385 // The Databricks ADBC driver does not allow specifying both a URI and
13841386 // individual connection options (e.g. catalog, schema). All connection
0 commit comments