Skip to content

Commit

Permalink
test(flink): update API calls for positional-only changes
Browse files Browse the repository at this point in the history
  • Loading branch information
cpcloud committed Feb 4, 2025
1 parent 9e09d07 commit a7e49ad
Showing 1 changed file with 11 additions and 11 deletions.
22 changes: 11 additions & 11 deletions ibis/backends/flink/tests/test_ddl.py
Original file line number Diff line number Diff line change
Expand Up @@ -186,7 +186,7 @@ def test_recreate_in_mem_table(con, schema, table_name, temp_table, csv_source_c
tbl_properties = None

new_table = con.create_table(
name=temp_table,
temp_table,
obj=employee_df,
schema=schema,
tbl_properties=tbl_properties,
Expand All @@ -203,7 +203,7 @@ def test_recreate_in_mem_table(con, schema, table_name, temp_table, csv_source_c
match=r"An error occurred while calling o\d+\.createTemporaryView",
):
new_table = con.create_table(
name=temp_table,
temp_table,
obj=employee_df,
schema=schema,
tbl_properties=tbl_properties,
Expand All @@ -229,7 +229,7 @@ def test_force_recreate_in_mem_table(con, schema_props, temp_table, csv_source_c
tbl_properties = None

new_table = con.create_table(
name=temp_table,
temp_table,
obj=employee_df,
schema=schema,
tbl_properties=tbl_properties,
Expand All @@ -242,7 +242,7 @@ def test_force_recreate_in_mem_table(con, schema_props, temp_table, csv_source_c

# force recreate the same table a second time should succeed
new_table = con.create_table(
name=temp_table,
temp_table,
obj=employee_df,
schema=schema,
tbl_properties=tbl_properties,
Expand Down Expand Up @@ -347,14 +347,14 @@ def test_create_view(
con, temp_table, awards_players_schema, csv_source_configs, temp_view, temp
):
table = con.create_table(
name=temp_table,
temp_table,
schema=awards_players_schema,
tbl_properties=csv_source_configs("awards_players"),
)
assert temp_table in con.list_tables()

con.create_view(
name=temp_view,
temp_view,
obj=table,
force=False,
temp=temp,
Expand All @@ -366,7 +366,7 @@ def test_create_view(
# Try to re-create the same view with `force=False`
with pytest.raises(Py4JJavaError):
con.create_view(
name=temp_view,
temp_view,
obj=table,
force=False,
temp=temp,
Expand All @@ -376,7 +376,7 @@ def test_create_view(

# Try to re-create the same view with `force=True`
con.create_view(
name=temp_view,
temp_view,
obj=table,
force=True,
temp=temp,
Expand All @@ -386,22 +386,22 @@ def test_create_view(

# Overwrite the view
con.create_view(
name=temp_view,
temp_view,
obj=table,
force=False,
temp=temp,
overwrite=True,
)
assert view_list == sorted(con.list_tables())

con.drop_view(name=temp_view, temp=temp, force=True)
con.drop_view(temp_view, temp=temp, force=True)
assert temp_view not in con.list_tables()


def test_rename_table(con, awards_players_schema, temp_table, csv_source_configs):
table_name = temp_table
con.create_table(
name=table_name,
table_name,
schema=awards_players_schema,
tbl_properties=csv_source_configs("awards_players"),
)
Expand Down

0 comments on commit a7e49ad

Please sign in to comment.