1414
1515class Scheduler (Generic [T ]):
1616
17- def schedule_periodic (self , data : T | None = None , interval : float | None = None ) -> None :
17+ def schedule_one_shot (self , data : T | None = None , interval : float | None = None ) -> None :
1818 raise NotImplementedError ()
1919
20- def schedule_one_shot (self , data : T | None = None , interval : float | None = None ) -> None :
20+ def schedule_periodic (self , data : T | None = None , interval : float | None = None ) -> None :
2121 raise NotImplementedError ()
2222
2323 def stop (self ) -> None :
@@ -36,16 +36,16 @@ def __enter__(self) -> Scheduler[T]:
3636 def __exit__ (self , exc_type : Any , exc_val : Any , exc_tb : Any ) -> None :
3737 self .stop ()
3838
39- def schedule_periodic (self , data : T | None = None , interval : float | None = None ) -> None :
40- interval = interval or self ._interval
41- self ._timer .start (interval , self ._execute_and_restart , [data ])
42- log .info ('Periodic execution scheduled' , data = data , interval = interval )
43-
4439 def schedule_one_shot (self , data : T | None = None , interval : float | None = None ) -> None :
4540 interval = interval or self ._interval
4641 self ._timer .start (interval , self ._safe_execute , [data ])
4742 log .info ('One-shot execution scheduled' , data = data , interval = interval )
4843
44+ def schedule_periodic (self , data : T | None = None , interval : float | None = None ) -> None :
45+ interval = interval or self ._interval
46+ self ._timer .start (interval , self ._execute_and_restart , [data ])
47+ log .info ('Periodic execution scheduled' , data = data , interval = interval )
48+
4949 def stop (self ) -> None :
5050 self ._timer .cancel ()
5151
0 commit comments