Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
lu-wang-dl committed May 30, 2024
1 parent c13ce83 commit 1c7736d
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions test/test_spark.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,10 +36,6 @@
register_spark()


def inc(x):
return x + 1


def slow_raise_value_error(condition, duration=0.05):
sleep(duration)
if condition:
Expand All @@ -65,6 +61,9 @@ def teardown_class(cls):
cls.spark.stop()

def test_simple(self):
def inc(x):
return x + 1

with parallel_backend('spark') as (ba, _):
seq = Parallel(n_jobs=5)(delayed(inc)(i) for i in range(10))
assert seq == [inc(i) for i in range(10)]
Expand Down

0 comments on commit 1c7736d

Please sign in to comment.