From 4cba09e97dfd6d0d507bfbd8332d1ddeac405a1f Mon Sep 17 00:00:00 2001 From: John Joyce Date: Thu, 22 Dec 2022 08:33:18 -0800 Subject: [PATCH] fix(ingest): Fixing lint (#6844) --- metadata-ingestion/src/datahub/configuration/kafka.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/metadata-ingestion/src/datahub/configuration/kafka.py b/metadata-ingestion/src/datahub/configuration/kafka.py index fa9b3a3c28..38430bdd34 100644 --- a/metadata-ingestion/src/datahub/configuration/kafka.py +++ b/metadata-ingestion/src/datahub/configuration/kafka.py @@ -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: