@@ -351,7 +351,7 @@ def test_delete__delete_rows():
351351 new_datadf = pd .DataFrame (
352352 {"UNIQUE_KEY" : ["test1" ], "test" : ["test1" ], "foo" : [1 ], "baz" : [float ("nan" )]}
353353 )
354- expecteddf = pd .DataFrame ({0 : ["2" , "3" ], 1 : ["3" , "5" ]})
354+ expecteddf = pd .DataFrame ({"ROW_ID" : ["2" , "3" ], "ROW_VERSION" : ["3" , "5" ]})
355355 delete_rows = process_functions ._delete_rows (new_datadf , DATABASE_DF , "UNIQUE_KEY" )
356356 assert delete_rows .equals (expecteddf )
357357
@@ -439,20 +439,24 @@ def test_create_new_fileformat_table(syn):
439439 )
440440 update_return = Mock ()
441441 move_entity_return = Mock ()
442- with patch .object (
443- process_functions , "get_dbmapping" , return_value = db_mapping_info
444- ) as patch_getdb , patch .object (
445- syn , "get" , return_value = table_ent
446- ) as patch_syn_get , patch .object (
447- syn , "getTableColumns" , return_value = ["foo" , "ddooo" ]
448- ) as patch_get_table_cols , patch .object (
449- process_functions , "_create_schema" , return_value = new_table_ent
450- ) as patch_create_schema , patch .object (
451- process_functions , "_update_database_mapping" , return_value = update_return
452- ) as patch_update , patch .object (
453- process_functions , "_move_entity" , return_value = move_entity_return
454- ) as patch_move , patch .object (
455- process_functions .time , "time" , return_value = 2
442+ with (
443+ patch .object (
444+ process_functions , "get_dbmapping" , return_value = db_mapping_info
445+ ) as patch_getdb ,
446+ patch .object (syn , "get" , return_value = table_ent ) as patch_syn_get ,
447+ patch .object (
448+ syn , "getTableColumns" , return_value = ["foo" , "ddooo" ]
449+ ) as patch_get_table_cols ,
450+ patch .object (
451+ process_functions , "_create_schema" , return_value = new_table_ent
452+ ) as patch_create_schema ,
453+ patch .object (
454+ process_functions , "_update_database_mapping" , return_value = update_return
455+ ) as patch_update ,
456+ patch .object (
457+ process_functions , "_move_entity" , return_value = move_entity_return
458+ ) as patch_move ,
459+ patch .object (process_functions .time , "time" , return_value = 2 ),
456460 ):
457461 new_table = process_functions .create_new_fileformat_table (
458462 syn , fileformat , new_table_name , project_id , archived_project_id
0 commit comments