fix: Making the query_timeout variable as optional int because upstream is considered to be optional (#4092)

lokeshrangineni · web-flow · commit fd5b620b2c56 · 2024-04-15T00:43:40.000-07:00
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):
