async def mark_entity_processed(self, sync_id: UUID, entity_id: str, chunk_count: int) -> None:
        """Mark an entity as fully processed after chunking.

        Args:
            sync_id: Sync ID
            entity_id: Entity ID
            chunk_count: Number of chunks created
        """
        metadata_blob = self._get_metadata_blob_name(sync_id, entity_id)

        # Get existing metadata
        metadata_bytes = await self.client.download_file(self.metadata_container, metadata_blob)

        if metadata_bytes:
            metadata = json.loads(metadata_bytes.decode("utf-8"))
            metadata.update(
                {
                    "fully_processed": True,
                    "chunk_count": chunk_count,
                    "processed_at": datetime.utcnow().isoformat(),
                }
            )

            # Update metadata
            await self._store_metadata(sync_id, entity_id, metadata)

            logger.info(
                "Marked entity as processed",
                extra={"sync_id": str(sync_id), "entity_id": entity_id, "chunk_count": chunk_count},
            )
Mark an entity as fully processed after chunking.

        Args:
            sync_id: Sync ID
            entity_id: Entity ID
            chunk_count: Number of chunks created
        
backend/airweave/platform/storage/storage_manager.py