def verify_appended_columns()

in pyspark-sdk/integration_test/BatchIngestionTest.py [0:0]

• 4 lines of code
• 1 McCabe index (conditional complexity)

def verify_appended_columns(row: Row):
    tc.assertEqual(str(row["is_deleted"]), "False")
    tc.assertEqual(datetime.fromisoformat(str(row["write_time"])),
                   datetime.fromisoformat(str(row["api_invocation_time"])))