Linting

Author: skrydal

metadata-ingestion/src/datahub/emitter/mcp_builder.py

@@ -159,7 +159,7 @@ def gen_containers(
     owner_urn: Optional[str] = None,
     external_url: Optional[str] = None,
     tags: Optional[List[str]] = None,
-    qualified_name: Optional[str] = None
+    qualified_name: Optional[str] = None,
 ) -> Iterable[MetadataWorkUnit]:
     container_urn = make_container_urn(
         guid=container_key.guid(),
@@ -174,7 +174,7 @@ def gen_containers(
             description=description,
             customProperties=container_key.dict(exclude_none=True, by_alias=True),
             externalUrl=external_url,
-            qualifiedName=qualified_name
+            qualifiedName=qualified_name,
         ),
     )
     wu = MetadataWorkUnit(id=f"container-info-{name}-{container_urn}", mcp=mcp)

metadata-ingestion/src/datahub/ingestion/source/aws/glue.py

@@ -292,7 +292,8 @@ def __init__(self, config: GlueSourceConfig, ctx: PipelineContext):
         )
 
     def get_glue_arn(
-            self, account_id: str, database: str, table: Optional[str] = None) -> str:
+        self, account_id: str, database: str, table: Optional[str] = None
+    ) -> str:
         prefix = f"arn:aws:glue:{self.source_config.aws_region}:{account_id}"
         if table:
             return f"{prefix}:table/{database}/{table}"
@@ -1135,9 +1136,9 @@ def get_dataset_properties() -> DatasetPropertiesClass:
                 uri=table.get("Location"),
                 tags=[],
                 qualifiedName=self.get_glue_arn(
-                    account_id = table["CatalogId"],
-                    database = table["DatabaseName"],
-                    table = table["Name"],
+                    account_id=table["CatalogId"],
+                    database=table["DatabaseName"],
+                    table=table["Name"],
                 ),
             )