From 8161a24daaab031a76094eab47d02a3d9ec4e91d Mon Sep 17 00:00:00 2001 From: Marcel Johannesmann Date: Tue, 21 May 2024 23:38:04 +0200 Subject: [PATCH] refactor: removed redundant check --- arroyo/processing/processor.py | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/arroyo/processing/processor.py b/arroyo/processing/processor.py index 631d3396..5789213c 100644 --- 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",