refactor: removed redundant check

getsentry · May 21, 2024 · 8161a24 · 8161a24
1 parent 091db6a
commit 8161a24
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/arroyo/processing/processor.py b/arroyo/processing/processor.py
@@ -143,9 +143,9 @@ def __init__(
         self.__processor_factory = processor_factory
         self.__metrics_buffer = MetricsBuffer()
 
-        self.__processing_strategy: Optional[
-            ProcessingStrategy[TStrategyPayload]
-        ] = None
+        self.__processing_strategy: Optional[ProcessingStrategy[TStrategyPayload]] = (
+            None
+        )
 
         self.__message: Optional[BrokerValue[TStrategyPayload]] = None
 
@@ -405,10 +405,8 @@ def _run_once(self) -> None:
             if self.__message is not None:
                 try:
                     start_submit = time.time()
-                    message = (
-                        Message(self.__message) if self.__message is not None else None
-                    )
-                    self.__processing_strategy.submit(message)
+
+                    self.__processing_strategy.submit(Message(self.__message))
 
                     self.__metrics_buffer.incr_timing(
                         "arroyo.consumer.processing.time",