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

remove sleeps

Browse source
This commit is contained in:
Daniel A. Wozniak 2023-08-05 13:08:24 -07:00 • committed by Gareth J. Greenaway
parent cf4e901ba8
commit 9a4da7d2e3
3 changed files with 1 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
salt/transport/tcp.py
View file

@ -201,10 +201,6 @@ class Resolver(tornado.netutil.DefaultLoopResolver):
Default resolver for tornado
"""
#def __init__(self, *args, **kwargs):
# super().configure('tornado.netutil.DefaultLoopResolver')
class TCPPubClient(salt.transport.base.PublishClient):
"""

4
tests/pytests/functional/transport/ipc/test_pub_server_channel.py
View file

@ -100,7 +100,6 @@ def test_issue_36469_tcp(salt_master, salt_minion, transport):
server_channel = salt.channel.server.PubServerChannel.factory(opts)
async def send():
await asyncio.sleep(0.3)
for idx in range(num):
load = {
"tgt_type": "glob",
@ -110,7 +109,7 @@ def test_issue_36469_tcp(salt_master, salt_minion, transport):
await server_channel.publish(load)
asyncio.run(send())
time.sleep(0.3)
# Allow some time for sends to finish
time.sleep(3)
server_channel.close()
loop.close()
@ -122,7 +121,6 @@ def test_issue_36469_tcp(salt_master, salt_minion, transport):
server_channel = salt.channel.server.PubServerChannel.factory(opts)
async def send():
await asyncio.sleep(0.3)
for idx in range(num):
load = {
"tgt_type": "glob",

1
tests/pytests/functional/transport/tcp/test_message_client.py
View file

@ -80,7 +80,6 @@ async def test_message_client_reconnect(config, client, server):
received.append(msg)
client.on_recv(handler)
await asyncio.sleep(0.03)
# Prepare two packed messages
msg = salt.utils.msgpack.dumps({"test": "test1"})
pmsg = salt.utils.msgpack.dumps({"head": {}, "body": msg})