Skip to content
Snippets Groups Projects
Commit 2219f765 authored by Sam Kagan's avatar Sam Kagan
Browse files

Merge branch 'fix-messaging' into 'main'

make sure index message post curation is for correct product

See merge request !1736
parents d7232fe1 749d42e2
No related branches found
No related tags found
2 merge requests!1740pull in changes from last patch,!1736make sure index message post curation is for correct product
......@@ -205,8 +205,14 @@ def send_indexer_message(parameters: dict, ingest_type: Union[IngestType, VLASSI
f"calibration {parameters['calSpl']} and project {parameters['project']}."
)
case CuratorType.FULL | CuratorType.PARTIAL:
# TODO: figure out how to handle this with non-EB products
msg = "obs" + msg_suffix
product_type = parameters["product_type"]
if product_type == "calibration":
msg_prefix = "cal"
elif product_type == "image":
msg_prefix = "img"
else:
msg_prefix = "obs"
msg = msg_prefix + msg_suffix
telescope = parameters["telescope"]
payload = {
"project_code": parameters["project"],
......
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