mirror of
https://github.com/huggingface/lerobot.git
synced 2026-05-21 11:39:50 +00:00
stop policy when we dont teleop yet
This commit is contained in:
@@ -379,13 +379,18 @@ def rac_rollout_loop(
|
|||||||
frame_buffer.append(frame)
|
frame_buffer.append(frame)
|
||||||
stats["total_frames"] += 1
|
stats["total_frames"] += 1
|
||||||
|
|
||||||
elif events["policy_paused"] and not waiting_for_takeover:
|
elif waiting_for_takeover:
|
||||||
|
# Waiting for START - policy stopped, no recording, robot holds position
|
||||||
|
if last_robot_action is not None:
|
||||||
|
robot.send_action(last_robot_action)
|
||||||
|
stats["paused_frames"] += 1
|
||||||
|
|
||||||
|
elif events["policy_paused"]:
|
||||||
# Paused and user acknowledged - hold last position, don't record
|
# Paused and user acknowledged - hold last position, don't record
|
||||||
if last_robot_action is not None:
|
if last_robot_action is not None:
|
||||||
robot.send_action(last_robot_action)
|
robot.send_action(last_robot_action)
|
||||||
stats["paused_frames"] += 1
|
stats["paused_frames"] += 1
|
||||||
robot_action = last_robot_action
|
robot_action = last_robot_action
|
||||||
# Don't record frames during pause
|
|
||||||
|
|
||||||
else:
|
else:
|
||||||
# Normal policy execution - record
|
# Normal policy execution - record
|
||||||
|
|||||||
@@ -397,7 +397,11 @@ def rac_rollout_loop(
|
|||||||
frame_buffer.append(frame)
|
frame_buffer.append(frame)
|
||||||
stats["total_frames"] += 1
|
stats["total_frames"] += 1
|
||||||
|
|
||||||
elif events["policy_paused"] and not waiting_for_takeover:
|
elif waiting_for_takeover:
|
||||||
|
# Waiting for START - policy stopped, no recording, robot holds position
|
||||||
|
stats["paused_frames"] += 1
|
||||||
|
|
||||||
|
elif events["policy_paused"]:
|
||||||
# Paused and user acknowledged - teleop tracks robot position, don't record
|
# Paused and user acknowledged - teleop tracks robot position, don't record
|
||||||
robot_action = {k: v for k, v in obs_filtered.items() if k.endswith(".pos")}
|
robot_action = {k: v for k, v in obs_filtered.items() if k.endswith(".pos")}
|
||||||
teleop.send_feedback(robot_action)
|
teleop.send_feedback(robot_action)
|
||||||
|
|||||||
Reference in New Issue
Block a user