Skip to content

Commit 8e232d3

Browse files
committed
last one
1 parent 523ba81 commit 8e232d3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

tests/packaged_modules/test_spark.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,8 +75,8 @@ def test_spark_examples_iterable():
7575
df = spark.range(10).repartition(1)
7676
it = SparkExamplesIterable(df)
7777
assert it.num_shards == 1
78-
for i, (row_id, row_dict) in enumerate(it):
79-
assert row_id == f"0_{i}"
78+
for i, (row_key, row_dict) in enumerate(it):
79+
assert row_key == (0, i)
8080
assert row_dict == {"id": i}
8181

8282

0 commit comments

Comments
 (0)