Skip to content

Commit 90d0a53

Browse files
committed
Try fix multi pipeline tests
1 parent c0dff44 commit 90d0a53

File tree

3 files changed

+7
-4
lines changed

3 files changed

+7
-4
lines changed

src/tomato/drivers/example_counter/counter.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def run_counter(self, conn):
3737
self.started_at = None
3838

3939
cmd = None
40-
if conn.poll(1e-6):
40+
if conn.poll(1e-3):
4141
cmd, attr, val = conn.recv()
4242

4343
if cmd == "set":
@@ -58,3 +58,5 @@ def run_counter(self, conn):
5858
elif cmd == "data":
5959
conn.send(data)
6060
data = []
61+
else:
62+
time.sleep(1e-3)

src/tomato/tomato/__init__.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -413,8 +413,9 @@ def reload(
413413
ret = _updater(context, port, "pipeline", params)
414414
if ret.success is False:
415415
return ret
416-
417-
req.send_pyobj(dict(cmd="status", with_data=True, sender=f"{__name__}.reload"))
416+
req.send_pyobj(
417+
dict(cmd="setup", settings=settings, sender=f"{__name__}.reload")
418+
)
418419
rep = req.recv_pyobj()
419420

420421
if rep.msg == "running":

tests/conftest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ def start_tomato_daemon(tmpdir: str, port: int = 12345):
3030
# setup_stuff
3131
os.chdir(tmpdir)
3232
subprocess.run(["tomato", "init", "-p", f"{port}", "-A", ".", "-D", "."])
33-
subprocess.run(["tomato", "start", "-p", f"{port}", "-A", ".", "-L", "."])
33+
subprocess.run(["tomato", "start", "-p", f"{port}", "-A", ".", "-L", ".", "-vv"])
3434
yield
3535
# teardown_stuff
3636

0 commit comments

Comments
 (0)