Skip to content
Snippets Groups Projects
Commit af6e2e99 authored by Charlotte Hausman's avatar Charlotte Hausman
Browse files

remove check for routing key

parent 23d71689
No related branches found
No related tags found
1 merge request!1042fix ingestion message catching for autocalibration
Pipeline #6470 passed
......@@ -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": {
......
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment