ref(decoder): Remove dead code (#167)

getsentry · Dec 21, 2022 · ad77984 · ad77984
1 parent 7d00296
commit ad77984
Showing 1 changed file with 0 additions and 10 deletions.
diff --git a/arroyo/processing/strategies/decoder.py b/arroyo/processing/strategies/decoder.py
@@ -21,16 +21,6 @@ class DecodedKafkaMessage(Generic[T]):
     headers: Sequence[Tuple[str, bytes]]
 
 
-def validation_func(
-    codec: Codec[T], validate: bool, message: Message[KafkaPayload]
-) -> DecodedKafkaMessage[T]:
-    return DecodedKafkaMessage(
-        message.payload.key,
-        codec.decode(message.payload.value, validate),
-        message.payload.headers,
-    )
-
-
 class KafkaMessageDecoder(ProcessingStrategy[KafkaPayload]):
     """
     Decode messages to be forwarded to the next step. Optional validation.