plugin pubsub cache: use asDeferred with match_cb

2021-08-02 21:52:17 +02:00 · 2021-08-02 21:52:17 +02:00 · 6fa6f7a1f8
commit 6fa6f7a1f8
parent 1d6cead380
1 changed files with 1 additions and 2 deletions
--- a/sat/plugins/plugin_pubsub_cache.py
+++ b/sat/plugins/plugin_pubsub_cache.py
@ -389,7 +389,6 @@ class PubsubCache:
                analyse["conf"] = conf

        for analyser in self.analysers.values():
-            match_cb = analyser.get("match_cb")
            try:
                an_node = analyser["node"]
            except KeyError:
@ -429,7 +428,7 @@ class PubsubCache:
            except KeyError:
                pass
            else:
-                await match_cb(client, analyse)
+                await utils.asDeferred(match_cb, client, analyse)
        return analyse

    def _getItemsFromCache(