From 7c1a9f3a5848afeeeaee80771d5b86ede215204b Mon Sep 17 00:00:00 2001 From: dspeck1 Date: Tue, 3 Dec 2024 13:02:21 -0600 Subject: [PATCH] Add ComCam support. --- src/main.py | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/src/main.py b/src/main.py index 45bf7e1..2b6bc24 100644 --- a/src/main.py +++ b/src/main.py @@ -125,6 +125,7 @@ async def main() -> None: # Keda environment variables prompt_processing_kafka_cluster = os.environ["PROMPT_PROCESSING_KAFKA_CLUSTER"] fan_out_comcamsim_topic = os.environ["FAN_OUT_COMCAMSIM_TOPIC"] + fan_out_comcam_topic = os.environ["FAN_OUT_COMCAM_TOPIC"] fan_out_hsc_topic = os.environ["FAN_OUT_HSC_TOPIC"] fan_out_latiss_topic = os.environ["FAN_OUT_LATISS_TOPIC"] fan_out_security_protocol = os.environ["FAN_OUT_KAFKA_SECURITY_PROTOCOL"] @@ -349,7 +350,15 @@ async def main() -> None: case "LSSTComCam": logging.info(f"Ignore LSSTComCam message {next_visit_message_updated}" " as the prompt service for this is not yet deployed.") - continue + fan_out_message_list = ( + next_visit_message_updated.add_detectors( + dataclasses.asdict(next_visit_message_updated), + # Just use ComCam active detector config. + lsstcomcam_active_detectors, + fan_out_delivery_time, + ) + ) + fan_out_topic = fan_out_comcam_topic case "LSSTCam": logging.info(f"Ignore LSSTCam message {next_visit_message_updated}" " as the prompt service for this is not yet deployed.")