diff --git a/ingestion/src/metadata/ingestion/ometa/ometa_api.py b/ingestion/src/metadata/ingestion/ometa/ometa_api.py index 383c48281c3..a0683616437 100644 --- a/ingestion/src/metadata/ingestion/ometa/ometa_api.py +++ b/ingestion/src/metadata/ingestion/ometa/ometa_api.py @@ -577,7 +577,7 @@ class OpenMetadata( return EntityReference( id=instance.id, type=get_entity_type(entity), - name=model_str(instance.fullyQualifiedName), + fullyQualifiedName=model_str(instance.fullyQualifiedName), description=instance.description, href=instance.href, ) diff --git a/ingestion/src/metadata/orm_profiler/processor/orm_profiler.py b/ingestion/src/metadata/orm_profiler/processor/orm_profiler.py index 58bde85eee9..68a85013bbb 100644 --- a/ingestion/src/metadata/orm_profiler/processor/orm_profiler.py +++ b/ingestion/src/metadata/orm_profiler/processor/orm_profiler.py @@ -311,19 +311,20 @@ class OrmProfilerProcessor(Processor[Table]): description=test_case.description, testDefinition=EntityReference( id=self.metadata.get_by_name( - fqn=test_definition.name, entity=TestDefinition + fqn=test_definition.fullyQualifiedName.__root__, + entity=TestDefinition, ).id.__root__, type="testDefinition", ), entity=EntityReference( id=self.metadata.get_by_name( - fqn=test_case.fullyQualifiedName, entity=Table + fqn=test_case.fullyQualifiedName.__root__, entity=Table ).id.__root__, type="table", ), testSuite=EntityReference( id=self.metadata.get_by_name( - fqn=test_suite.name, entity=TestSuite + fqn=test_suite.fullyQualifiedName.__root__, entity=TestSuite ).id.__root__, type="testSuite", ), diff --git a/ingestion/tests/integration/orm_profiler/test_orm_profiler.py b/ingestion/tests/integration/orm_profiler/test_orm_profiler.py index faea5f40f57..f7b890e26f5 100644 --- a/ingestion/tests/integration/orm_profiler/test_orm_profiler.py +++ b/ingestion/tests/integration/orm_profiler/test_orm_profiler.py @@ -23,7 +23,6 @@ import pytest from sqlalchemy import Column, Integer, String, create_engine from sqlalchemy.orm import declarative_base -from metadata.config.common import WorkflowExecutionError from metadata.generated.schema.entity.data.table import Table from metadata.generated.schema.entity.services.connections.metadata.openMetadataConnection import ( OpenMetadataConnection, diff --git a/ingestion/tests/unit/profiler/test_workflow.py b/ingestion/tests/unit/profiler/test_workflow.py index fcd390c971c..b04fe7c398f 100644 --- a/ingestion/tests/unit/profiler/test_workflow.py +++ b/ingestion/tests/unit/profiler/test_workflow.py @@ -36,9 +36,7 @@ from metadata.generated.schema.type.entityReference import EntityReference from metadata.orm_profiler.api.models import ProfilerProcessorConfig from metadata.orm_profiler.api.workflow import ProfilerWorkflow from metadata.orm_profiler.interfaces.sqa_profiler_interface import SQAProfilerInterface -from metadata.orm_profiler.processor.orm_profiler import OrmProfilerProcessor from metadata.orm_profiler.profiler.default import DefaultProfiler -from metadata.orm_profiler.profiler.models import ProfilerDef TABLE = Table( id=uuid.uuid4(),