Update Entity Reference parameter fields (#6841)

This commit is contained in:
Ayush Shah 2022-08-22 19:37:24 +05:30 committed by GitHub
parent 51bf63551e
commit 383f4497cc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 5 additions and 7 deletions

View File

@ -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,
)

View File

@ -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",
),

View File

@ -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,

View File

@ -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(),