From b2770f1df91e00c1d737ed2b05bfd8eb873c844f Mon Sep 17 00:00:00 2001 From: ma052025 Date: Mon, 30 Jun 2025 13:26:18 +0200 Subject: [PATCH] fix table arn for GlueTableForm --- .../post_dq_results_to_datazone.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/transforms/GlueDQResultToDataZonePublisher/post_dq_results_to_datazone.py b/examples/transforms/GlueDQResultToDataZonePublisher/post_dq_results_to_datazone.py index 8eb9901..1243402 100644 --- a/examples/transforms/GlueDQResultToDataZonePublisher/post_dq_results_to_datazone.py +++ b/examples/transforms/GlueDQResultToDataZonePublisher/post_dq_results_to_datazone.py @@ -178,7 +178,7 @@ def search_asset_id(datazone, dzDomain, tableName, schemaName, maxResults: int) forms_dict['RedshiftTableForm']['schemaName'] == schemaName and forms_dict['RedshiftTableForm']['tableName'] == tableName) or \ ('GlueTableForm' in forms_dict and - f"table/{schemaName}/{tableName}" in forms_dict['GlueTableForm']['tableArn']): + f"{schemaName}/{tableName}" in forms_dict['GlueTableForm']['tableArn']): entity_identifier=item['assetListing']['entityId'] get_logger().info(f"DZ Asset Id: {entity_identifier_list}") entity_identifier_list.append(entity_identifier)