Commit 9b220ed 1 parent d259e91 commit 9b220ed Copy full SHA for 9b220ed
File tree 1 file changed +7
-2
lines changed
metadata-ingestion/src/datahub/ingestion/api
1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change
1
+ import json
1
2
import logging
2
3
from datetime import datetime , timezone
3
4
from typing import (
@@ -80,12 +81,16 @@ def create_dataset_props_patch_builder(
80
81
81
82
def check_mcp_correctness (mcp : MetadataChangeProposalClass ):
82
83
logger .debug (f"Processing as MCP with urn: { mcp .entityUrn } and aspect: { mcp .aspectName } , change type: { mcp .changeType } " )
83
- logger .debug (f"{ mcp .aspect } " )
84
+ logger .debug (f"Aspect length: { len (mcp .aspect .value )} " )
85
+ logger .debug (f"Full aspect:\n { mcp .aspect } " )
84
86
85
87
86
88
def check_mcpw_correctness (mcp : MetadataChangeProposalWrapper ):
87
89
logger .debug (f"Processing as MCP with urn: { mcp .entityUrn } and aspect: { mcp .aspectName } , change type: { mcp .changeType } " )
88
- logger .debug (f"{ mcp .aspect } " )
90
+ logger .debug (f"Full aspect:\n { mcp .aspect } " )
91
+ if isinstance (mcp .aspect , SchemaMetadataClass ):
92
+ schema : SchemaMetadataClass = mcp .aspect
93
+ logger .debug (f"Schema aspect dump:\n { json .dumps (schema , indent = 4 )} " )
89
94
90
95
91
96
def check_workunit_correctness (stream : Iterable [MetadataWorkUnit ]) -> Iterable [MetadataWorkUnit ]:
You can’t perform that action at this time.
0 commit comments