yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-01 11:09:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: table column description (#23928)

Browse Source
This commit is contained in:
Keshav Mohta 2025-10-20 09:59:23 +05:30 committed by GitHub
parent e49d3ee31a
commit 7ea87e7ca2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ingestion/src/metadata/ingestion/source/database/salesforce/metadata.py
View File

@ -184,9 +184,11 @@ class SalesforceSource(DatabaseServiceSource):
)
if filter_by_table(
self.config.sourceConfig.config.tableFilterPattern,
table_fqn
if self.config.sourceConfig.config.useFqnForFiltering
else table_name,
(
table_fqn
if self.config.sourceConfig.config.useFqnForFiltering
else table_name
),
):
self.status.filter(
table_fqn,
@ -238,7 +240,7 @@ class SalesforceSource(DatabaseServiceSource):
all_column_description = None
try:
result = self.client.toolingexecute(
f"query/?q=SELECT+Description+FROM+FieldDefinition+WHERE+"
f"query/?q=SELECT+Description, QualifiedApiName+FROM+FieldDefinition+WHERE+"
f"EntityDefinition.QualifiedApiName='{table_name}'"
)
all_column_description = result["records"]
@ -313,7 +315,7 @@ class SalesforceSource(DatabaseServiceSource):
for item in all_column_description:
try:
if item.get("Description") is not None:
column_name = item["attributes"]["url"].split(".")[-1]
column_name = item["QualifiedApiName"]
column_description_mapping.update(
{column_name: item["Description"]}
)

6
ingestion/tests/unit/topology/database/test_salesforce.py
View File

@ -215,7 +215,7 @@ SALESFORCE_FIELDS = [
("htmlFormatted", False),
("idLookup", False),
("inlineHelpText", None),
("label", "Contact Description"),
("label", "Contact Label"),
("length", 32000),
("mask", None),
("maskType", None),
@ -453,7 +453,9 @@ class SalesforceUnitTest(TestCase):
"metadata.ingestion.source.database.salesforce.metadata.SalesforceSource.get_table_column_description"
)
def test_table_column(self, get_table_column_description):
get_table_column_description.return_value = None
get_table_column_description.return_value = [
{"QualifiedApiName": "Description", "Description": "Contact Description"}
]
result = self.salesforce_source.get_columns("TEST_TABLE", SALESFORCE_FIELDS)
assert EXPECTED_COLUMN_VALUE == result