saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Do not override kwargs

Browse source
This commit is contained in:
Daniel A. Wozniak 2023-07-31 14:42:44 -07:00 • committed by Gareth J. Greenaway
parent 43a3863532
commit d8d6bf1630
1 changed files with 2 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
salt/transport/tcp.py
View file

@ -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: