We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ff7bd5c commit bb525daCopy full SHA for bb525da
src/saf/process/job_aggregate.py
@@ -7,6 +7,7 @@
7
8
import fnmatch
9
import logging
10
+import pprint
11
from typing import TYPE_CHECKING
12
from typing import AsyncIterator
13
from typing import Dict
@@ -62,7 +63,9 @@ async def process(
62
63
Aggregate received events, otherwise store in cache.
64
"""
65
if isinstance(event, EventBusCollectedEvent):
66
+ log.debug("Event Bus Collected Event:\n%s", pprint.pformat(event.dict()))
67
salt_event = event.salt_event
68
+ log.debug("Event Bus Collected Salt Event:\n%s", pprint.pformat(salt_event))
69
tag = salt_event.tag
70
data = salt_event.data
71
if "watched_jids" not in ctx.cache:
0 commit comments