Skip to content

Commit 50c5e49

Browse files
committed
feat!: Make MP processor be more hard fail
1 parent dec7e7d commit 50c5e49

2 files changed

Lines changed: 9 additions & 2 deletions

File tree

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
class MappingSuiteProcessorServiceError(Exception):
2+
pass

ted_sws/mapping_suite_processor/services/conceptual_mapping_processor.py

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
from ted_sws.data_manager.adapters.notice_repository import NoticeRepository
1313
from ted_sws.event_manager.services.log import log_mapping_suite_info, log_mapping_suite_error
1414
from ted_sws.mapping_suite_processor.adapters.github_package_downloader import GitHubMappingSuitePackageDownloader
15+
from ted_sws.mapping_suite_processor.services import MappingSuiteProcessorServiceError
1516
from ted_sws.mapping_suite_processor.services.mapping_suite_digest_service import \
1617
update_digest_api_address_for_mapping_suite
1718
from ted_sws.mapping_suite_processor.services.mapping_suite_validation_service import validate_mapping_suite, \
@@ -98,9 +99,11 @@ def mapping_suite_processor_from_github_expand_and_load_package_in_mongo_db(mong
9899
validation_result = validate_mapping_suite(mapping_suite_path=mapping_suite_package_path)
99100
mapping_suite_id = get_mapping_suite_id_from_file_system(mapping_suite_path=mapping_suite_package_path)
100101
if mapping_suite_id is None:
102+
error_msg = "Invalid mapping suite metadata, can't read mapping suite identifier!"
101103
log_mapping_suite_error(
102-
message="Invalid mapping suite metadata, can't read mapping suite identifier!",
104+
message=error_msg,
103105
mapping_suite_id=MAPPING_SUITE_UNKNOWN_ID)
106+
raise MappingSuiteProcessorServiceError(error_msg)
104107
elif validation_result:
105108
log_mapping_suite_info(
106109
message=f"Mapping suite with id={mapping_suite_id} is valid for loading in MongoDB!",
@@ -115,8 +118,10 @@ def mapping_suite_processor_from_github_expand_and_load_package_in_mongo_db(mong
115118
message=f"Mapping suite with id={mapping_suite_id} loaded with success in MongoDB!",
116119
mapping_suite_id=mapping_suite_id)
117120
else:
121+
error_msg = f"Mapping suite with id={mapping_suite_id} is invalid for loading in MongoDB!"
118122
log_mapping_suite_error(
119-
message=f"Mapping suite with id={mapping_suite_id} is invalid for loading in MongoDB!",
123+
message=error_msg,
120124
mapping_suite_id=mapping_suite_id)
125+
raise MappingSuiteProcessorServiceError(error_msg)
121126

122127
return result_notice_ids

0 commit comments

Comments
 (0)