fix: Making the query_timeout variable as optional int because upstre…

…am is considered to be optional (#4092)
feast-dev · Apr 15, 2024 · fd5b620 · fd5b620
1 parent 3afa78e
commit fd5b620
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
@@ -21,7 +21,7 @@
 class SparkProcessorConfig(ProcessorConfig):
     spark_session: SparkSession
     processing_time: str
-    query_timeout: int
+    query_timeout: Optional[int] = None
 
 
 class SparkKafkaProcessor(StreamProcessor):