diff --git a/beavers/testing.py b/beavers/testing.py index dc7a528..8f8d8e0 100644 --- a/beavers/testing.py +++ b/beavers/testing.py @@ -2,7 +2,7 @@ import pandas as pd -from beavers.engine import UTC_MAX, Dag +from beavers.engine import Dag T = TypeVar("T") @@ -26,12 +26,6 @@ def run(self, now: Optional[pd.Timestamp] = None) -> "DagTestBench": self.dag.stabilize(now) return self - def run_for_next_timer(self) -> "DagTestBench": - next_timer = self.dag.get_next_timer() - assert next_timer != UTC_MAX - self.dag.stabilize(next_timer) - return self - def assert_sink_list( self, sink_name: str,