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 @@ -236,7 +236,7 @@ def copy_into_table_from_stage(
236
236
# Check if the data was loaded successfully
237
237
if cur .fetchall ()[0 ][1 ] == "LOADED" :
238
238
print (
239
- f"cloudprober_driver_python_create_stage {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 0"
239
+ f"cloudprober_driver_python_copy_data_from_stage_into_table {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 0"
240
240
)
241
241
else :
242
242
print (
@@ -337,16 +337,16 @@ def compare_fetched_data(
337
337
for y in range (len (fetched_data [0 ])):
338
338
if str (fetched_data [random_index ][y ]) != csv_data [random_index ][y ]:
339
339
print (
340
- f"cloudprober_driver_python_data_transferred_completely {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 1"
340
+ f"cloudprober_driver_python_data_integrity {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 1"
341
341
)
342
342
sys .exit (1 )
343
343
print (
344
- f"cloudprober_driver_python_data_data_integrity {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 0"
344
+ f"cloudprober_driver_python_data_integrity {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 0"
345
345
)
346
346
except Exception as e :
347
347
logger .error (f"Error comparing fetched data: { e } " )
348
348
print (
349
- f"cloudprober_driver_python_data_data_integrity {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 1"
349
+ f"cloudprober_driver_python_data_integrity {{python_version={ get_python_version ()} , driver_version={ get_driver_version ()} }} 1"
350
350
)
351
351
sys .exit (1 )
352
352
You can’t perform that action at this time.
0 commit comments