From ee29394c36a6e9c5c288aebe0f4332e3dd7cebf4 Mon Sep 17 00:00:00 2001 From: Abhishek-N Date: Tue, 26 Mar 2024 21:49:08 +0530 Subject: [PATCH] validate table columns --- tests/warehouse/test_bigquery_ops.py | 4 ---- tests/warehouse/test_postgres_ops.py | 4 ---- 2 files changed, 8 deletions(-) diff --git a/tests/warehouse/test_bigquery_ops.py b/tests/warehouse/test_bigquery_ops.py index d2c9864..2b4a85e 100644 --- a/tests/warehouse/test_bigquery_ops.py +++ b/tests/warehouse/test_bigquery_ops.py @@ -984,7 +984,3 @@ def test_flattenjson(self): assert "_airbyte_data_NGO" in cols assert "_airbyte_data_Month" in cols assert "_airbyte_ab_id" in cols - - table_data = wc_client.get_table_data("pytest_intermediate", output_name, 1) - assert table_data[0]["_airbyte_data_NGO"] == 'BAMANEH' - assert table_data[0]["_airbyte_data_SPOC"] == 'SPOC A' diff --git a/tests/warehouse/test_postgres_ops.py b/tests/warehouse/test_postgres_ops.py index 2cee1c5..a84b18a 100644 --- a/tests/warehouse/test_postgres_ops.py +++ b/tests/warehouse/test_postgres_ops.py @@ -776,10 +776,6 @@ def test_flattenjson(self): assert "_airbyte_data_Month" in cols assert "_airbyte_ab_id" in cols - table_data = wc_client.get_table_data("pytest_intermediate", output_name, 1) - assert table_data[0]["_airbyte_data_NGO"] == 'BAMANEH' - assert table_data[0]["_airbyte_data_SPOC"] == 'SPOC A' - def test_merge_operation(self): """test merge_operation""" wc_client = TestPostgresOperations.wc_client