Method _execute_task

core/task_executor.py:74–131

Execute a single task using the full run_agent() pipeline. Installs a daemon shell guard and disables interactive confirmations for the duration of the call, then unconditionally restores the previous AGENT_CONFIG values so interactive sessions are unaffected.

(self, prompt: str)

    # ------------------------------------------------------------------

    async def _execute_task(self, prompt: str) -> str:
        """
        Execute a single task using the full run_agent() pipeline.

        Installs a daemon shell guard and disables interactive confirmations
        for the duration of the call, then unconditionally restores the
        previous AGENT_CONFIG values so interactive sessions are unaffected.

        The prompt should already be the enriched step string produced by
        daemon._handle_command (includes original task + step number).
        """
        start_inference()
        try:
            from core.agent import run_agent
            from prompts.layered_prompt import invalidate_prompt_cache

            # Fresh file context for every step — previous steps may have
            # written files that must appear in this step's system prompt.
            invalidate_prompt_cache()

            # Clear working memory between daemon steps — previous step's
            # files and turn counter bleed into this step causing stale
            # context and premature LRU eviction of files we haven't seen yet.
            from core.memory import memory as _mem
            _mem.clear()

            # Save and override AGENT_CONFIG for daemon execution.
            _saved = {
                "_shell_fn":     AGENT_CONFIG.get("_shell_fn"),
                "confirm_shell": AGENT_CONFIG.get("confirm_shell"),
                "confirm_write": AGENT_CONFIG.get("confirm_write"),
            }
            AGENT_CONFIG["_shell_fn"]     = self._daemon_shell
            AGENT_CONFIG["confirm_shell"] = False  # guard is in _daemon_shell
            AGENT_CONFIG["confirm_write"] = False  # daemon writes without prompting

            try:
                loop = asyncio.get_event_loop()
                response, _ = await loop.run_in_executor(
                    None,
                    lambda: run_agent(
                        prompt,
                        history=[],
                        yolo=True,
                        no_plan=True,      # each daemon step is already planned
                        _in_subtask=True,  # suppress git prompts; scale max_steps
                    ),
                )
                return response
            finally:
                AGENT_CONFIG.update(_saved)

        except Exception as e:
            import traceback
            error(f"Task execution error: {e}\n{traceback.format_exc()}")
            raise  # re-raise original exception; already logged above
        finally:
            end_inference()