Method flush_task

python/valuecell/core/event/buffer.py:263–275

Finalize and emit all buffered aggregates for a given task context. This writes current aggregates (using their stable paragraph item_id) and clears the corresponding buffers. Use at task end (success or fail).

(
        self,
        conversation_id: str,
        thread_id: Optional[str],
        task_id: Optional[str],
    )

        return out

    def flush_task(
        self,
        conversation_id: str,
        thread_id: Optional[str],
        task_id: Optional[str],
    ) -> List[SaveItem]:
        """Finalize and emit all buffered aggregates for a given task context.

        This writes current aggregates (using their stable paragraph item_id)
        and clears the corresponding buffers. Use at task end (success or fail).
        """
        keys_to_flush = self._collect_task_keys(conversation_id, thread_id, task_id)
        return self._finalize_keys(keys_to_flush)

    def _make_save_item_from_response(self, resp: BaseResponse) -> SaveItem:
        data: UnifiedResponseData = resp.data