diff --git a/inventory_provider/routes/poller.py b/inventory_provider/routes/poller.py
index f15d9727227f304ddcf33bdefd446309460e0a76..e89a977eaae04a65271caee32cc30f33a5a96c25 100644
--- a/inventory_provider/routes/poller.py
+++ b/inventory_provider/routes/poller.py
@@ -915,17 +915,20 @@ def interfaces(hostname=None):
     return Response(result, mimetype="application/json")
 
 
-def get_netdash_equipment() -> Dict[str, str]:
+def get_netdash_equipment(config, use_next_redis=False) -> Dict[str, str]:
     """Get the netdash equipment mapping from redis."""
-    current_redis = common.get_current_redis()
-    return json.loads(current_redis.get('netdash').decode('utf-8'))
+    if use_next_redis:
+        r = tasks_common.get_next_redis(config)
+    else:
+        r = tasks_common.get_current_redis(config)
+    return json.loads(r.get('netdash').decode('utf-8'))
 
 
 def load_error_report_interfaces(
     config, hostname=None, use_next_redis=False
 ):
     interfaces = _load_interfaces(config, hostname, use_next_redis=use_next_redis)
-    netdash_equipment = get_netdash_equipment()
+    netdash_equipment = get_netdash_equipment(config, use_next_redis)
 
     def filter_interface(interface: dict):
         return all(