diff --git a/core/events/ohlcv.py b/core/events/ohlcv.py
index 8b69ab5a..6edc07a9 100644
--- 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
index 3506801d..6cde8328 100644
--- 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
index 3ab4ef7c..6d22641d 100644
--- 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))