async def is_entity_fully_processed(self, cache_key: str) -> bool:
        """Check if an entity has been fully processed (including chunking).

        Args:
            cache_key: Format "sync_id/entity_id"

        Returns:
            True if entity was fully processed
        """
        try:
            # Check metadata to see if processing was completed
            parts = cache_key.split("/")
            if len(parts) != 2:
                return False

            sync_id, entity_id = parts[0], parts[1]
            metadata_blob = self._get_metadata_blob_name(UUID(sync_id), entity_id)

            metadata_bytes = await self.client.download_file(self.metadata_container, metadata_blob)

            if metadata_bytes:
                metadata = json.loads(metadata_bytes.decode("utf-8"))
                return metadata.get("fully_processed", False)

        except Exception as e:
            logger.debug(f"Error checking if entity is fully processed: {e}")

        return False
Check if an entity has been fully processed (including chunking).

        Args:
            cache_key: Format "sync_id/entity_id"

        Returns:
            True if entity was fully processed
        
backend/airweave/platform/storage/storage_manager.py