External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-03-20 02:17:37 -02:30
Code Issues Packages Projects Releases Wiki Activity

fix: keep processing events, even if previous event data cannot be pa… (#15965) (#6922)

Browse Source 
* fix: keep processing events, even if previous event data cannot be parsed

* change log level to warning
This commit is contained in:
Peter Braun
2025-05-05 13:26:42 +02:00
committed by GitHub
parent 2bc08b421d
commit 0e28d2590a
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
awx/main/tasks/host_indirect.py
View File

@@ -77,7 +77,14 @@ def build_indirect_host_data(job: Job, job_event_queries: dict[str, dict[str, st
if jq_str_for_event not in compiled_jq_expressions: if jq_str_for_event not in compiled_jq_expressions:
compiled_jq_expressions[resolved_action] = jq.compile(jq_str_for_event) compiled_jq_expressions[resolved_action] = jq.compile(jq_str_for_event)
compiled_jq = compiled_jq_expressions[resolved_action] compiled_jq = compiled_jq_expressions[resolved_action]
for data in compiled_jq.input(event.event_data['res']).all():
try:
data_source = compiled_jq.input(event.event_data['res']).all()
except Exception as e:
logger.warning(f'error for module {resolved_action} and data {event.event_data["res"]}: {e}')
continue
for data in data_source:
# From this jq result (specific to a single Ansible module), get index information about this host record # From this jq result (specific to a single Ansible module), get index information about this host record
if not data.get('canonical_facts'): if not data.get('canonical_facts'):
if not facts_missing_logged: if not facts_missing_logged: