Skip to content

Commit b06cf3a

Browse files
authored
Hotfix default name (#226)
1 parent 8ea48ac commit b06cf3a

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

aiomisc/service/carbon.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ class CarbonSender(Service):
3434
protocol: str = "udp"
3535
namespace: Iterable[str] = ("",)
3636
storage = TotalStorage
37+
name: str = "carbon-sender"
3738
_handle: PeriodicCallback
3839

3940
async def start(self) -> None:
@@ -50,7 +51,7 @@ async def start(self) -> None:
5051

5152
set_client(client)
5253

53-
self._handle = PeriodicCallback(client.send, name="carbon-sender")
54+
self._handle = PeriodicCallback(client.send, name=self.name)
5455
self._handle.start(self.send_interval, loop=self.loop)
5556
log.info(
5657
"Periodic carbon metrics sender started. Send to %s://%s:%d with "

aiomisc/service/periodic.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,10 @@ class PeriodicService(Service):
1414

1515
interval: Union[int, float]
1616
delay: Union[int, float] = 0
17-
name: str = "carbon-sender"
1817

1918
def __init__(self, *, name: Optional[str] = None, **kwargs: Any):
2019
super().__init__(**kwargs)
21-
self.periodic = PeriodicCallback(self.callback, name=self.name)
20+
self.periodic = PeriodicCallback(self.callback, name=name)
2221

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

0 commit comments

Comments
 (0)