small bug fix
This commit is contained in:
1 parent
06c0366d2a
commit
cdce46c033
1 file changed
+4
@@ -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):
|
||||
|
||||
Reference in new issue
Block a user