diff --git a/src/main.py b/src/main.py index 56d7267..3951d99 100644 --- a/src/main.py +++ b/src/main.py @@ -597,6 +597,7 @@ async def main() -> None: gauges, hsc_upload_detectors, ) + logging.info(type(send_info) dispatch_fanned_out_messages_redis_stream(redis_client, redis_stream, tasks, send_info) except UnsupportedMessageError: logging.exception("Could not process message, continuing.")