From 12b4bf80bc5c90830999b24ac5c7a8cb3fe6405b Mon Sep 17 00:00:00 2001 From: Arthur Date: Wed, 15 Nov 2023 08:34:41 -0800 Subject: [PATCH] 14132 optimize flush_events --- netbox/extras/events.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/netbox/extras/events.py b/netbox/extras/events.py index 0c138d538..610f544ac 100644 --- a/netbox/extras/events.py +++ b/netbox/extras/events.py @@ -137,9 +137,10 @@ def flush_events(queue): """ Flush a list of object representation to RQ for webhook processing. """ - for name in settings.NETBOX_EVENTS_PIPELINE: - try: - func = module_member(name) - func(queue) - except Exception as e: - logger.error(f"Cannot import events pipeline {name} error: {e}") + if queue: + for name in settings.NETBOX_EVENTS_PIPELINE: + try: + func = module_member(name) + func(queue) + except Exception as e: + logger.error(f"Cannot import events pipeline {name} error: {e}")