Repository navigation

Commit fd5b620

lokeshrangineni

authored

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

1 parent 3afa78e commit fd5b620Copy full SHA for fd5b620

1 file changed

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

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

-Original file line number
+Diff line change
 class SparkProcessorConfig(ProcessorConfig):
     spark_session: SparkSession
     processing_time: str
 -    query_timeout: int
 +    query_timeout: Optional[int] = None
 class SparkKafkaProcessor(StreamProcessor):

Comments

(0)