Skip to content
Snippets Groups Projects

fix ingestion message catching for autocalibration

Merged Charlotte Hausman requested to merge 2.5_ingestion_messaging into main
@@ -194,13 +194,12 @@ class ArchiveService(ArchiveServiceIF):
"""
log_data = message["logData"]
routing_key = message["routing_key"]
sdm_id = log_data["fileset_id"]
sb_type = log_data["schedblock_type"]
telescope = log_data["telescope"]
if sb_type != "OBSERVER" or telescope != "EVLA" or "ingestion-complete.rawdata" not in routing_key:
if sb_type != "OBSERVER" or telescope != "EVLA":
# not a candidate for std_calibration
return None
Loading