From 9291a063a944dd07cacbf02fa3d1aa4c8e1bf1ed Mon Sep 17 00:00:00 2001 From: Lokesh Rangineni Date: Wed, 10 Apr 2024 16:46:10 -0400 Subject: [PATCH] making the query_timeout variable as optional int because upstream timeout is also optional. This is expected to fix the issue - https://github.com/feast-dev/feast/issues/3799 Signed-off-by: Lokesh Rangineni --- sdk/python/feast/infra/contrib/spark_kafka_processor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py index fc4a34f17bd..e148000bc96 100644 --- 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):