# HG changeset patch # User Goffi # Date 1627933937 -7200 # Node ID 32181a45d54b725bbc3550ddb4241fc2622cf096 # Parent 7f503b20597eb52990599087a99cc528030b2470 plugin pubsub cache: use `asDeferred` with `match_cb` diff -r 7f503b20597e -r 32181a45d54b sat/plugins/plugin_pubsub_cache.py --- a/sat/plugins/plugin_pubsub_cache.py Mon Aug 02 21:52:17 2021 +0200 +++ b/sat/plugins/plugin_pubsub_cache.py Mon Aug 02 21:52:17 2021 +0200 @@ -389,7 +389,6 @@ 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 @@ except KeyError: pass else: - await match_cb(client, analyse) + await utils.asDeferred(match_cb, client, analyse) return analyse def _getItemsFromCache(