address comments

metaphor/kafka/config.py

@@ -141,7 +141,7 @@ class KafkaConfig(BaseConfig):
     """
 
     bootstrap_servers: List[KafkaBootstrapServer] = dataclass_field(
-        default_factory=lambda: []
+        default_factory=list
     )
     """
     The Kafka bootstrap servers / brokers. Cannot be empty.

metaphor/postgresql/config.py

@@ -1,6 +1,7 @@
 from dataclasses import field
 from typing import Dict, Optional, Set
 
+from pydantic import field_validator
 from pydantic.dataclasses import dataclass
 
 from metaphor.common.aws import AwsCredentials
@@ -28,6 +29,13 @@ class QueryLogConfig:
     # Config to link user name to email so that Metaphor can display each query's issuer.
     username_to_email: Dict[str, str] = field(default_factory=dict)
 
+    @field_validator("username_to_email")
+    def _normalize_emails(cls, username_to_email: Dict[str, str]):
+        return {
+            k: v.lower()
+            for k, v
+            in username_to_email.items()
+        }
 
 @dataclass(config=ConnectorConfig)
 class BasePostgreSQLRunConfig(BaseConfig):

tests/redshift/test_extractor.py

@@ -97,7 +97,7 @@ async def __anext__(self):
         config.query_log = QueryLogConfig(
             username_to_email={
                 "user1": "[email protected]",
-                "user2": "[email protected]",
+                "user2": "[email protected]",
             }
         )
         extractor = RedshiftExtractor(config)