Skip to content

Commit

Permalink
Fix integration test
Browse files Browse the repository at this point in the history
Signed-off-by: Luca Della Vedova <[email protected]>
  • Loading branch information
luca-della-vedova committed Dec 13, 2024
1 parent 3452bf7 commit e12f7b6
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 5 deletions.
2 changes: 1 addition & 1 deletion nexus_integration_tests/launch/office.launch.xml
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
<?xml version='1.0' ?>

<launch>
<arg name="headless" default="false"/>
<arg name="headless" default="true"/>
<arg name="use_simulator" default="true"/>
<arg name="sim_update_rate" default='100'/>

Expand Down
2 changes: 1 addition & 1 deletion nexus_integration_tests/test_parallel_wo.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ async def asyncSetUp(self):
subprocess.Popen('pkill -9 -f zenoh', shell=True)

self.proc = managed_process(
("ros2", "launch", "nexus_integration_tests", "office.launch.xml"),
("ros2", "launch", "nexus_integration_tests", "office.launch.xml", "sim_update_rate:=10000"),
)
self.proc.__enter__()
print("waiting for nodes to be ready...", file=sys.stderr)
Expand Down
7 changes: 4 additions & 3 deletions nexus_integration_tests/test_pick_and_place.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ async def asyncSetUp(self):
subprocess.Popen('pkill -9 -f zenoh', shell=True)

self.proc = managed_process(
("ros2", "launch", "nexus_integration_tests", "office.launch.xml"),
("ros2", "launch", "nexus_integration_tests", "office.launch.xml", "sim_update_rate:=10000"),
)
self.proc.__enter__()
print("waiting for nodes to be ready...", file=sys.stderr)
Expand Down Expand Up @@ -90,8 +90,9 @@ def on_fb(msg):
# high load so we only check the last feedback as a workaround.
self.assertGreater(len(feedbacks), 0)
for msg in feedbacks:
self.assertEqual(len(msg.task_states), 1)
state: TaskState = msg.task_states[0] # type: ignore
# The first task is transportation
self.assertEqual(len(msg.task_states), 2)
state: TaskState = msg.task_states[1] # type: ignore
self.assertEqual(state.workcell_id, "workcell_2")
self.assertEqual(state.task_id, "1")

Expand Down

0 comments on commit e12f7b6

Please sign in to comment.