async def verify_asana_tasks_in_weaviate(sync_id: uuid.UUID):
    """Example of a more connector-specific verification for Asana:
    filtering tasks using Weaviate's property filter and printing details.
    """
    print("\n=== Verifying Asana Tasks in Weaviate ===")
    async with WeaviateService() as service:
        sanitized_sync_id = str(sync_id).replace("-", "_")
        collection: Collection = await service.get_weaviate_collection(
            f"Chunks_{sanitized_sync_id}"
        )

        # Query tasks with filters (e.g. resource_subtype == default_task)
        tasks = await collection.query.fetch_objects(
            limit=5,
            filters=wvc.query.Filter.by_property("resource_subtype").equal("default_task"),
            return_metadata=wvc.query.MetadataQuery(creation_time=True),
        )

        print("\nSample tasks:")
        for task in tasks.objects:
            print(f"Task: {task.properties.get('name')}")
            print(f"Created: {task.metadata.creation_time}")
            print(f"Completed: {task.properties.get('completed')}")
            print(f"Due at: {task.properties.get('due_at')}")
            print("-----")
Example of a more connector-specific verification for Asana:
    filtering tasks using Weaviate's property filter and printing details.
    
backend/local.py