Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 6 additions & 10 deletions tests/providers/openlineage/test_sqlparser.py
Original file line number Diff line number Diff line change
Expand Up @@ -283,12 +283,9 @@ def test_generate_openlineage_metadata_from_sql(self, mock_parse, parser_returns
]

sql = """INSERT INTO popular_orders_day_of_week (order_day_of_week)
SELECT EXTRACT(ISODOW FROM order_placed_on) AS order_day_of_week
FROM top_delivery_times
--irrelevant comment
)
;
"""
SELECT EXTRACT(ISODOW FROM order_placed_on) AS order_day_of_week
FROM top_delivery_times --irrelevant comment
);"""

hook.get_conn.return_value.cursor.return_value.fetchall.side_effect = returned_rows

Expand All @@ -314,10 +311,9 @@ def test_generate_openlineage_metadata_from_sql(self, mock_parse, parser_returns
mock_parse.return_value = mock_sql_meta

formatted_sql = """INSERT INTO popular_orders_day_of_week (order_day_of_week)
SELECT EXTRACT(ISODOW FROM order_placed_on) AS order_day_of_week
FROM top_delivery_times

)"""
SELECT EXTRACT(ISODOW FROM order_placed_on) AS order_day_of_week
FROM top_delivery_times
)"""
expected_schema = "PUBLIC" if parser_returns_schema else "ANOTHER_SCHEMA"
expected = OperatorLineage(
inputs=[
Expand Down