From d8d6bf1630818b13a8c3d955174bdb48312426fa Mon Sep 17 00:00:00 2001 From: "Daniel A. Wozniak" Date: Mon, 31 Jul 2023 14:42:44 -0700 Subject: [PATCH] Do not override kwargs --- salt/transport/tcp.py | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/salt/transport/tcp.py b/salt/transport/tcp.py index b119d7d8322..d9a7cddfc73 100644 --- a/salt/transport/tcp.py +++ b/salt/transport/tcp.py @@ -285,10 +285,7 @@ class TCPPubClient(salt.transport.base.PublishClient): async def getstream(self, **kwargs): if self.source_ip or self.source_port: - kwargs = { - "source_ip": self.source_ip, - "source_port": self.source_port, - } + kwargs.update(source_ip=self.source_ip, source_port=self.source_port) stream = None start = time.monotonic() timeout = kwargs.get("timeout", None) @@ -1671,10 +1668,7 @@ class TCPReqClient(salt.transport.base.RequestClient): async def getstream(self, **kwargs): if self.source_ip or self.source_port: - kwargs = { - "source_ip": self.source_ip, - "source_port": self.source_port, - } + kwargs.update(source_ip=self.source_ip, source_port=self.source_port) stream = None while stream is None and (not self._closed and not self._closing): try: