async def verify_chunks_in_weaviate(sync_id: uuid.UUID):
    """Check total chunk count in the corresponding Weaviate collection,
    and print some sample documents.
    """
    print("\n=== Verifying Sync Results ===")
    async with WeaviateService() as service:
        sanitized_sync_id = str(sync_id).replace("-", "_")
        collection: Collection = await service.get_weaviate_collection(
            f"Chunks_{sanitized_sync_id}"
        )

        # Count how many chunk objects are in this collection
        count = (await collection.aggregate.over_all(total_count=True)).total_count
        print(f"\nTotal documents in 'Chunks_{sanitized_sync_id}' collection: {count}")

        # Fetch some sample documents (no filter)
        results = await collection.query.fetch_objects(limit=5, include_vector=False)
        print("\nSample objects:")
        for obj in results.objects:
            print(f"\nName: {obj.properties.get('name')}")
            print(f"Source: {obj.properties.get('source_name')}")
            print(f"Created: {obj.metadata.creation_time}")
            print(f"Breadcrumbs: {obj.properties.get('breadcrumbs')}")
Check total chunk count in the corresponding Weaviate collection,
    and print some sample documents.
    
backend/local.py