Skip to content

Commit fb8affc

Browse files
committed
Add comments
1 parent 38910ec commit fb8affc

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

tests/integration/test_writes/test_optimistic_concurrency.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
def test_conflict_delete_delete(
3030
spark: SparkSession, session_catalog: Catalog, arrow_table_with_null: pa.Table, format_version: int
3131
) -> None:
32+
"""This test should start passing once optimistic concurrency control has been implemented."""
3233
identifier = "default.test_conflict"
3334
tbl1 = _create_table(session_catalog, identifier, {"format-version": format_version}, [arrow_table_with_null])
3435
tbl2 = session_catalog.load_table(identifier)
@@ -45,6 +46,7 @@ def test_conflict_delete_delete(
4546
def test_conflict_delete_append(
4647
spark: SparkSession, session_catalog: Catalog, arrow_table_with_null: pa.Table, format_version: int
4748
) -> None:
49+
"""This test should start passing once optimistic concurrency control has been implemented."""
4850
identifier = "default.test_conflict"
4951
tbl1 = _create_table(session_catalog, identifier, {"format-version": format_version}, [arrow_table_with_null])
5052
tbl2 = session_catalog.load_table(identifier)
@@ -62,6 +64,7 @@ def test_conflict_delete_append(
6264
def test_conflict_append_delete(
6365
spark: SparkSession, session_catalog: Catalog, arrow_table_with_null: pa.Table, format_version: int
6466
) -> None:
67+
"""This test should start passing once optimistic concurrency control has been implemented."""
6568
identifier = "default.test_conflict"
6669
tbl1 = _create_table(session_catalog, identifier, {"format-version": format_version}, [arrow_table_with_null])
6770
tbl2 = session_catalog.load_table(identifier)
@@ -78,6 +81,7 @@ def test_conflict_append_delete(
7881
def test_conflict_append_append(
7982
spark: SparkSession, session_catalog: Catalog, arrow_table_with_null: pa.Table, format_version: int
8083
) -> None:
84+
"""This test should start passing once optimistic concurrency control has been implemented."""
8185
identifier = "default.test_conflict"
8286
tbl1 = _create_table(session_catalog, identifier, {"format-version": format_version}, [arrow_table_with_null])
8387
tbl2 = session_catalog.load_table(identifier)

0 commit comments

Comments
 (0)