mirror of
https://github.com/huggingface/lerobot.git
synced 2026-05-21 19:49:49 +00:00
fix: catch KeyboardInterrupt in safe_stop_image_writer to prevent corrupted frames (#3381)
This commit is contained in:
@@ -30,13 +30,13 @@ def safe_stop_image_writer(func):
|
|||||||
def wrapper(*args, **kwargs):
|
def wrapper(*args, **kwargs):
|
||||||
try:
|
try:
|
||||||
return func(*args, **kwargs)
|
return func(*args, **kwargs)
|
||||||
except Exception as e:
|
except BaseException:
|
||||||
dataset = kwargs.get("dataset")
|
dataset = kwargs.get("dataset")
|
||||||
writer = getattr(dataset, "writer", None) if dataset else None
|
writer = getattr(dataset, "writer", None) if dataset else None
|
||||||
if writer is not None and writer.image_writer is not None:
|
if writer is not None and writer.image_writer is not None:
|
||||||
logger.warning("Waiting for image writer to terminate...")
|
logger.warning("Waiting for image writer to terminate...")
|
||||||
writer.image_writer.stop()
|
writer.image_writer.stop()
|
||||||
raise e
|
raise
|
||||||
|
|
||||||
return wrapper
|
return wrapper
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user