File tree Expand file tree Collapse file tree 1 file changed +9
-3
lines changed
Expand file tree Collapse file tree 1 file changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -295,6 +295,7 @@ def check_database_changes(
295295 changes ["to_delete_rows" ] = to_delete_rows
296296 return changes
297297
298+
298299def store_database (
299300 syn : synapseclient .Synapse ,
300301 database_table_synid : str ,
@@ -314,12 +315,17 @@ def store_database(
314315 table_entity = syn .get (database_table_synid )
315316 # upsert table with new and updated rows
316317 if not all_updates .empty :
317- Table (id = database_table_synid ).store_rows (all_updates , to_csv_kwargs = {"float_format" : "%.12g" })
318+ Table (id = database_table_synid ).store_rows (
319+ all_updates , to_csv_kwargs = {"float_format" : "%.12g" }
320+ )
318321 logger .info (f"Upserting { len (all_updates )} rows from { table_entity .name } table" )
319322 # delete rows from the database
320323 if not to_delete_rows .empty :
321- Table (id = database_table_synid ).delete_rows (to_delete_rows )
322- logger .info (f"Deleting { len (to_delete_rows )} rows from { table_entity .name } table" )
324+ Table (id = database_table_synid ).delete_rows (to_delete_rows )
325+ logger .info (
326+ f"Deleting { len (to_delete_rows )} rows from { table_entity .name } table"
327+ )
328+
323329
324330def _copyRecursive (
325331 syn : synapseclient .Synapse ,
You can’t perform that action at this time.
0 commit comments