Skip to content

Commit f692c10

Browse files
Try catch wrap for processing
1 parent 035f134 commit f692c10

1 file changed

Lines changed: 21 additions & 21 deletions

File tree

scripts/agents/get_aguvis_data.py

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -396,32 +396,32 @@ def get_images_total_weight(images_folder: Path, image_paths: list) -> int:
396396
print(f"Error getting image weight: {e}", images_folder, image_paths)
397397
return 0
398398

399-
processed_data = []
400-
current_weight = 0
401-
shard_number = 0
402-
MAX_WEIGHT = 1000 * 1024 * 1024
403399

404400
def process_items() -> Generator[Dict[str, Any], None, None]:
405401
pbar = tqdm(data)
406402
for item in pbar:
407403
# Extract image paths from the data item
408-
image_paths = []
409-
if "images" in item:
410-
image_paths = (
411-
item["images"]
412-
if isinstance(item["images"], list)
413-
else [item["images"]]
414-
)
415-
elif "image" in item:
416-
image_paths = [item["image"]]
417-
418-
# Load images
419-
images = load_images_from_folder(images_folder, image_paths)
420-
421-
texts = convert_to_chat_format(item)
422-
423-
entry = {"images": images, "texts": texts}
424-
yield entry
404+
try:
405+
image_paths = []
406+
if "images" in item:
407+
image_paths = (
408+
item["images"]
409+
if isinstance(item["images"], list)
410+
else [item["images"]]
411+
)
412+
elif "image" in item:
413+
image_paths = [item["image"]]
414+
415+
# Load images
416+
images = load_images_from_folder(images_folder, image_paths)
417+
418+
texts = convert_to_chat_format(item)
419+
420+
entry = {"images": images, "texts": texts}
421+
yield entry
422+
except Exception as e:
423+
print(f"Error processing item: {e}", item)
424+
continue
425425
return process_items
426426

427427

0 commit comments

Comments
 (0)