From 560b24f1a65fc5219ccc8c587f0d7dff03bb5f12 Mon Sep 17 00:00:00 2001 From: Pedro Algarvio Date: Thu, 25 Jan 2024 16:13:26 +0000 Subject: [PATCH] Fix a few `yield` statements which should have been converted to `await` Signed-off-by: Pedro Algarvio --- salt/transport/zeromq.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/salt/transport/zeromq.py b/salt/transport/zeromq.py index 1caed8a23b3..73db20586ea 100644 --- a/salt/transport/zeromq.py +++ b/salt/transport/zeromq.py @@ -968,18 +968,18 @@ class PublishServer(salt.transport.base.DaemonizedPublishServer): htopic = salt.utils.stringutils.to_bytes( hashlib.sha1(salt.utils.stringutils.to_bytes(topic)).hexdigest() ) - yield self.dpub_sock.send_multipart([htopic, payload]) + await self.dpub_sock.send_multipart([htopic, payload]) log.trace("Filtered data has been sent") # Syndic broadcast if self.opts.get("order_masters"): log.trace("Sending filtered data to syndic") - yield self.dpub_sock.send_multipart([b"syndic", payload]) + await self.dpub_sock.send_multipart([b"syndic", payload]) log.trace("Filtered data has been sent to syndic") # otherwise its a broadcast else: # TODO: constants file for "broadcast" log.trace("Sending broadcasted data over publisher %s", self.pub_uri) - yield self.dpub_sock.send_multipart([b"broadcast", payload]) + await self.dpub_sock.send_multipart([b"broadcast", payload]) log.trace("Broadcasted data has been sent") else: log.trace("Sending ZMQ-unfiltered data over publisher %s", self.pub_uri)