From cdce46c03322f54a7de456c00799cd69d2728304 Mon Sep 17 00:00:00 2001 From: TPV Date: Thu, 16 Jul 2026 05:41:15 -0700 Subject: [PATCH] small bug fix --- src/monitor_utils/runner.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/monitor_utils/runner.py b/src/monitor_utils/runner.py index 89487d7..8d58a84 100644 --- a/src/monitor_utils/runner.py +++ b/src/monitor_utils/runner.py @@ -260,6 +260,10 @@ async def execute_monitor_logic( LOGGER.exception("Unexpected error") raise + if concurrent_pre_task_func: + tasks.append(concurrent_pre_task_func(session=session, **kwargs)) + category_keys.append("pre_task") + results = await asyncio.gather(*tasks, return_exceptions=True) for category_identifier, result in zip(category_keys, results): if isinstance(result, EXPECTED_TASK_ERRORS):