Method _safe_drain

libs/code/deepagents_code/app.py:3893–3904

()

        if self._deferred_actions and not self._agent_running:

            async def _safe_drain() -> None:
                try:
                    await self._maybe_drain_deferred()
                except Exception:
                    logger.exception("Unhandled error while draining deferred actions")
                    with suppress(Exception):
                        await self._mount_message(
                            ErrorMessage(
                                "A deferred action failed during startup. "
                                "You may need to retry the operation.",
                            ),
                        )

            self.call_after_refresh(lambda: asyncio.create_task(_safe_drain()))