fix metadata-ingestion:lint issues

datahub-project · May 30, 2024 · c13679b · c13679b
1 parent 3ae5127
commit c13679b
Show file tree

Hide file tree

Showing 3 changed files with 1,457 additions and 529 deletions.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/confluent_schema_registry.py b/metadata-ingestion/src/datahub/ingestion/source/confluent_schema_registry.py
@@ -369,10 +369,6 @@ def _get_schema_metadata(
         self, dataset_subtype: str, platform_urn: str, is_subject: bool
     ) -> Optional[SchemaMetadata]:
 
-        schema: Optional[Schema] = None
-        key_schema: Optional[Schema] = None
-        fields: List[SchemaField] = []
-        key_fields: List[SchemaField] = []
         # Process the value schema
         schema, fields = self._get_schema_and_fields(
             dataset_subtype=dataset_subtype,
@@ -415,10 +411,6 @@ def get_schema_metadata(
     ) -> Optional[SchemaMetadata]:
         logger.debug(f"Inside get_schema_metadata {dataset_subtype} {platform_urn}")
 
-        schema: Optional[Schema] = None
-        key_schema: Optional[Schema] = None
-        fields: List[SchemaField] = []
-        key_fields: List[SchemaField] = []
         # Process the value schema
         schema, fields = self._get_schema_and_fields(
             dataset_subtype=dataset_subtype,