Skip to content

Commit

Permalink
fix: log str process events
Browse files Browse the repository at this point in the history
  • Loading branch information
talboren committed Nov 28, 2024
1 parent a04e8c1 commit 31e8444
Showing 1 changed file with 9 additions and 0 deletions.
9 changes: 9 additions & 0 deletions keep/api/tasks/process_event_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -529,6 +529,7 @@ def process_event(
), # Let's log the events if we store it for debugging
}
logger.info("Processing event", extra=extra_dict)

raw_event = copy.deepcopy(event)
try:
session = get_session_sync()
Expand Down Expand Up @@ -568,6 +569,14 @@ def process_event(
)
return

if isinstance(event, str):
extra_dict["raw_event"] = event
logger.error(
"Event is a string (malformed json?), skipping processing",
extra=extra_dict,
)
return None

# In case when provider_type is not set
if isinstance(event, dict):
event = [AlertDto(**event)]
Expand Down

0 comments on commit 31e8444

Please sign in to comment.