From fd5b620b2c56c56286a5899b271da426c1a4ef67 Mon Sep 17 00:00:00 2001 From: lokeshrangineni Date: Mon, 15 Apr 2024 03:43:40 -0400 Subject: [PATCH] fix: Making the query_timeout variable as optional int because upstream is considered to be optional (#4092) --- 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 fc4a34f17b..e148000bc9 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):