Skip to content

Commit 04c97cf

Browse files
committed
Allow to set custom periodic names
1 parent 33239d6 commit 04c97cf

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

aiomisc/recurring.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,14 +48,14 @@ class RecurringCallback:
4848

4949
def __init__(
5050
self, coroutine_func: CallbackType,
51-
*args: Any, **kwargs: Any,
51+
*args: Any, name: Optional[str] = None, **kwargs: Any,
5252
):
5353
self.func: Callable[..., Awaitable[Any]]
5454
self.args: Tuple[Any, ...]
5555
self.kwargs: Mapping[str, Any]
5656
self._statistic: RecurringCallbackStatistic
5757

58-
self.name: str = repr(coroutine_func)
58+
self.name: str = name or repr(coroutine_func)
5959
self._statistic = RecurringCallbackStatistic(name=self.name)
6060
self.func = utils.awaitable(coroutine_func)
6161
self.args = args

aiomisc/service/periodic.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@ class PeriodicService(Service):
1515
interval: Union[int, float]
1616
delay: Union[int, float] = 0
1717

18-
def __init__(self, **kwargs: Any):
18+
def __init__(self, *, name: Optional[str] = None, **kwargs: Any):
1919
super().__init__(**kwargs)
20-
self.periodic = PeriodicCallback(self.callback)
20+
self.periodic = PeriodicCallback(self.callback, name=name)
2121

2222
async def start(self) -> None:
2323
assert self.interval, f"Interval illegal interval {self.interval!r}"

0 commit comments

Comments
 (0)