fix: more style fixes

openedx · Aug 9, 2022 · c027df5 · c027df5
1 parent 38bfaa6
commit c027df5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/edx_event_bus_kafka/config.py b/edx_event_bus_kafka/config.py
@@ -18,14 +18,15 @@ def create_schema_registry_client() -> Optional[SchemaRegistryClient]:
         warnings.warn("Cannot configure event-bus-kafka: Missing setting EVENT_BUS_KAFKA_SCHEMA_REGISTRY_URL")
         return None
 
-    key    = getattr(settings, 'EVENT_BUS_KAFKA_SCHEMA_REGISTRY_API_KEY', '')
+    key = getattr(settings, 'EVENT_BUS_KAFKA_SCHEMA_REGISTRY_API_KEY', '')
     secret = getattr(settings, 'EVENT_BUS_KAFKA_SCHEMA_REGISTRY_API_SECRET', '')
 
     return SchemaRegistryClient({
         'url': url,
         'basic.auth.user.info': f"{key}:{secret}",
     })
 
+
 def load_common_settings() -> Optional[dict]:
     """
     Load common settings, a base for either producer or consumer configuration.
@@ -39,7 +40,7 @@ def load_common_settings() -> Optional[dict]:
         'bootstrap.servers': bootstrap_servers,
     }
 
-    key    = getattr(base_settings, 'EVENT_BUS_KAFKA_API_KEY', None)
+    key = getattr(base_settings, 'EVENT_BUS_KAFKA_API_KEY', None)
     secret = getattr(base_settings, 'EVENT_BUS_KAFKA_API_SECRET', None)
 
     if key and secret: