diff --git a/shared/workspaces/test/test_archive_service.py b/shared/workspaces/test/test_archive_service.py index 4f4f04816ba341a7656346cb876fe3d043876140..2b540f962e7bb7126ff418993adf42aa8544dd24 100644 --- a/shared/workspaces/test/test_archive_service.py +++ b/shared/workspaces/test/test_archive_service.py @@ -135,7 +135,6 @@ class TestArchiveService: Do not submit VLASS calibrations for ingestion. """ ingestion_message = { - "routing_key": "i.am.key", "user": "test_user", "hostname": "hostname01", "timestamp": { @@ -180,7 +179,6 @@ class TestArchiveService: Do not submit TSKY calibrations for ingestion. """ ingestion_message = { - "routing_key": "i.am.key", "user": "test_user", "hostname": "hostname01", "timestamp": { diff --git a/shared/workspaces/workspaces/system/services/archive_service.py b/shared/workspaces/workspaces/system/services/archive_service.py index 6f744d1ff4f769da63612c17b58aa0f6035f05c7..c97bf971febb20e1d38e524ead77b67af09d10e1 100644 --- a/shared/workspaces/workspaces/system/services/archive_service.py +++ b/shared/workspaces/workspaces/system/services/archive_service.py @@ -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