fix(ingest): Fixing lint (#6844)

This commit is contained in:
John Joyce 2022-12-22 08:33:18 -08:00 committed by GitHub
parent 0f8e2d945e
commit 4cba09e97d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -16,7 +16,10 @@ class _KafkaConnectionConfig(ConfigModel):
description="Extra schema registry config serialized as JSON. These options will be passed into Kafka's SchemaRegistryClient. https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html?#schemaregistryclient",
)
client_timeout_seconds: int = Field(default=60, description="The request timeout used when interacting with the Kafka APIs.")
client_timeout_seconds: int = Field(
default=60,
description="The request timeout used when interacting with the Kafka APIs.",
)
@validator("bootstrap")
def bootstrap_host_colon_port_comma(cls, val: str) -> str: