Fix deduplication function

core/db/__init__.py

@@ -334,6 +334,7 @@ class StorageBackend(ABC):
             if not dedup_fields:
                 dedup_fields = ["msg", "nick", "ident", "host", "net", "channel"]
             response = helpers.dedup_list(response, dedup_fields)
+        return response
 
     @abstractmethod
     def parse(self, response):

core/db/druid.py

@@ -227,7 +227,7 @@ class DruidBackend(StorageBackend):
         response = self.query(request.user, search_query)
 
         # A/D/R - Annotate/Dedup/Reverse
-        self.process_results(
+        response = self.process_results(
             response,
             annotate=annotate,
             dedup=dedup,

core/db/elastic.py

@@ -325,7 +325,7 @@ class ElasticsearchBackend(StorageBackend):
             return response
 
         # A/D/R - Annotate/Dedup/Reverse
-        self.process_results(
+        response["object_list"] = self.process_results(
             response["object_list"],
             annotate=annotate,
             dedup=dedup,