fix(ingest/mongodb): schema_metadata referenced before assignment (datahub-project#10169)

sid-acryl · sleeperdeep · commit 870cce21d581 · 2024-06-25T11:09:19.000+03:00
diff --git a/metadata-ingestion/src/datahub/ingestion/source/mongodb.py b/metadata-ingestion/src/datahub/ingestion/source/mongodb.py
@@ -394,6 +394,8 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
                     customProperties={},
                 )
 
+                schema_metadata: Optional[SchemaMetadata] = None
+
                 if self.config.enableSchemaInference:
                     assert self.config.maxDocumentSize is not None
                     collection_schema = construct_schema_pymongo(

Original file line number	Diff line number	Diff line change
`@@ -394,6 +394,8 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:`
`394`	`394`	`customProperties={},`
`395`	`395`	`)`
`396`	`396`
	`397`	`+ schema_metadata: Optional[SchemaMetadata] = None`
	`398`	`+`
`397`	`399`	`if self.config.enableSchemaInference:`
`398`	`400`	`assert self.config.maxDocumentSize is not None`
`399`	`401`	`collection_schema = construct_schema_pymongo(`