upd

YieldsLabs · Sep 19, 2024 · 3c3baa9 · 3c3baa9
1 parent 672fe9d
commit 3c3baa9
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 10 deletions.
diff --git a/core/events/ohlcv.py b/core/events/ohlcv.py
@@ -1,4 +1,5 @@
 from dataclasses import dataclass, field
+
 from core.models.entity.bar import Bar
 from core.models.symbol import Symbol
 from core.models.timeframe import Timeframe

diff --git a/feed/_historical.py b/feed/_historical.py
@@ -122,11 +122,7 @@ async def _process_batch(self, batch: List[Bar]):
 
     async def _handle_market(self, batch: List[Bar]) -> None:
         for bar in batch:
-            await self.tell(
-                NewMarketDataReceived(
-                    self.symbol, self.timeframe, bar
-                )
-            )
+            await self.tell(NewMarketDataReceived(self.symbol, self.timeframe, bar))
         await asyncio.sleep(0.0001)
 
     async def _outbox(self, batch: List[Bar]) -> None:

diff --git a/feed/_realtime.py b/feed/_realtime.py
@@ -99,8 +99,4 @@ async def _process_bars(self, bars: List[Bar]):
 
                 logger.info(f"{self.symbol}_{self.timeframe}:{bar}")
 
-            await self.tell(
-                NewMarketDataReceived(
-                    self.symbol, self.timeframe, bar
-                )
-            )
+            await self.tell(NewMarketDataReceived(self.symbol, self.timeframe, bar))