Skip to content

Commit f362079

Browse files
committed
assert eventually does not care about tick
1 parent 6c53c74 commit f362079

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[project]
22
name = "resonate-sdk"
3-
version = "0.1.15"
3+
version = "0.1.16"
44
description = "Distributed Async Await by Resonate HQ, Inc"
55
authors = [
66
{ name = "Resonate HQ, Inc", email = "contact@resonatehq.io" }

src/resonate/dst/scheduler.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ def __init__( # noqa: PLR0913
115115
failure_chance: float,
116116
mode: Mode,
117117
probe: Callable[[Dependencies, int], Any] | None,
118-
assert_eventually: Callable[[Dependencies, int, int], None] | None,
118+
assert_eventually: Callable[[Dependencies, int], None] | None,
119119
assert_always: Callable[[Dependencies, int, int], None] | None,
120120
) -> None:
121121
self._assert_eventually = assert_eventually
@@ -379,7 +379,7 @@ def _run(self) -> list[Promise[Any]]: # noqa: C901
379379
assert_never(next_step)
380380

381381
if self._assert_eventually is not None:
382-
self._assert_eventually(self.deps, self.seed, self.tick)
382+
self._assert_eventually(self.deps, self.seed)
383383

384384
assert all(p.done() for p in promises), "All promises should be resolved."
385385
if self._log_file is not None:

src/resonate/testing.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ def dst( # noqa: PLR0913
2828
max_failures: int = 0,
2929
probe: Callable[[Dependencies, int], Any] | None = None,
3030
assert_always: Callable[[Dependencies, int, int], Any] | None = None,
31-
assert_eventually: Callable[[Dependencies, int, int], Any] | None = None,
31+
assert_eventually: Callable[[Dependencies, int], Any] | None = None,
3232
) -> list[DSTScheduler]:
3333
schedulers: list[DSTScheduler] = []
3434

0 commit comments

Comments
 (0)