async def bulk_delete(self, entity_ids: list[str], sync_id: UUID) -> None:
        """Bulk delete entities from Qdrant.

        Args:
            entity_ids (list[str]): The IDs of the entities to delete.
            sync_id (UUID): The sync ID.
        """
        if not entity_ids:
            return

        await self.ensure_client_readiness()

        await self.client.delete(
            collection_name=self.collection_name,
            points_selector=rest.FilterSelector(
                filter=rest.Filter(
                    must=[
                        rest.FieldCondition(
                            key="sync_id", match=rest.MatchValue(value=str(sync_id))
                        ),
                        rest.FieldCondition(key="entity_id", match=rest.MatchAny(any=entity_ids)),
                    ]
                )
            ),
            wait=True,  # Wait for operation to complete
        )
Bulk delete entities from Qdrant.

        Args:
            entity_ids (list[str]): The IDs of the entities to delete.
            sync_id (UUID): The sync ID.
        
backend/airweave/platform/destinations/qdrant.py