NeoAnd/netbox
1
0
Fork 0
mirror of https://github.com/netbox-community/netbox.git synced 2025-08-23 16:06:43 -06:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

14132 optimize flush_events

Browse Source
This commit is contained in:
Arthur 2023-11-15 08:34:41 -08:00
parent a2f542774d
commit 12b4bf80bc
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
netbox/extras/events.py
View File

@ -137,9 +137,10 @@ def flush_events(queue):
""" """
Flush a list of object representation to RQ for webhook processing. Flush a list of object representation to RQ for webhook processing.
""" """
for name in settings.NETBOX_EVENTS_PIPELINE: if queue:
try: for name in settings.NETBOX_EVENTS_PIPELINE:
func = module_member(name) try:
func(queue) func = module_member(name)
except Exception as e: func(queue)
logger.error(f"Cannot import events pipeline {name} error: {e}") except Exception as e:
logger.error(f"Cannot import events pipeline {name} error: {e}")