From 9e555a30adf0d56d256f240320bfdd4e5ffdfa02 Mon Sep 17 00:00:00 2001 From: Ali Behjati Date: Wed, 18 Oct 2023 13:06:11 +0200 Subject: [PATCH] fix pre-commit and bump version --- example_publisher/publisher.py | 4 +++- example_publisher/pythd.py | 4 +++- pyproject.toml | 2 +- 3 files changed, 7 insertions(+), 3 deletions(-) diff --git a/example_publisher/publisher.py b/example_publisher/publisher.py index ca4caf1..8ef0fbe 100644 --- a/example_publisher/publisher.py +++ b/example_publisher/publisher.py @@ -49,7 +49,9 @@ def __init__(self, config: Config) -> None: async def start(self): await self.pythd.connect() - self._product_update_task = asyncio.create_task(self._start_product_update_loop()) + self._product_update_task = asyncio.create_task( + self._start_product_update_loop() + ) async def _start_product_update_loop(self): await self._upd_products() diff --git a/example_publisher/pythd.py b/example_publisher/pythd.py index c61c480..51e7b57 100644 --- a/example_publisher/pythd.py +++ b/example_publisher/pythd.py @@ -70,7 +70,9 @@ async def subscribe_price_sched(self, account: str) -> int: def _notify_price_sched(self, subscription: int) -> None: log.debug("notify_price_sched RPC call received", subscription=subscription) - task = asyncio.get_event_loop().create_task(self.on_notify_price_sched(subscription)) + task = asyncio.get_event_loop().create_task( + self.on_notify_price_sched(subscription) + ) self._notify_price_sched_tasks.add(task) task.add_done_callback(lambda: self._notify_price_sched_tasks.remove(task)) diff --git a/pyproject.toml b/pyproject.toml index f8ea5cc..1c491c4 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "example-publisher" -version = "1.0.1" +version = "1.0.2" description = "" authors = [] license = "Apache-2"