fix: Making the query_timeout variable as optional int because upstream is considered to be optional by lokeshrangineni · Pull Request #4092 · feast-dev/feast · Shell

◐ Shell reader mode source ↗

sdk/python/feast/infra/contrib/spark_kafka_processor.py

-Original file line number
+Diff line change
@@ Expand Up / @@ -21,7 +21,7 @@ @@
     class SparkProcessorConfig(ProcessorConfig):
         spark_session: SparkSession
         processing_time: str
-        query_timeout: int
     class SparkKafkaProcessor(StreamProcessor):
@@ Expand Down @@

Toggle all file notes Toggle all file annotations