Method retry_task

src/task_manager.rs:184–257

Retry a task by creating a new task with the same instructions. Creates a duplicate task with a new ID, optionally allowing instruction editing. The original task must have been executed (not Queued) to be retried.

(
        &self,
        task_id: &str,
        edit_instructions: bool,
        overrides: RetryOverrides,
        ctx: &AppContext,
    )

    /// Creates a duplicate task with a new ID, optionally allowing instruction editing.
    /// The original task must have been executed (not Queued) to be retried.
    pub async fn retry_task(
        &self,
        task_id: &str,
        edit_instructions: bool,
        overrides: RetryOverrides,
        ctx: &AppContext,
    ) -> Result<String, String> {
        // Retrieve the original task
        let original_task = self
            .task_storage
            .get_task(task_id)
            .await
            .map_err(|e| format!("Error getting task: {e}"))?;

        let original_task = match original_task {
            Some(task) => task,
            None => return Err(format!("Task with ID '{task_id}' not found")),
        };

        // Validate that the task has been executed (not Queued)
        if original_task.status == TaskStatus::Queued {
            return Err("Cannot retry a task that hasn't been executed yet".to_string());
        }

        // Use TaskBuilder to create the new task, leveraging from_existing
        let mut builder = TaskBuilder::from_existing(&original_task);

        builder = builder.edit(edit_instructions);

        // Apply optional overrides
        if let Some(name) = overrides.name {
            builder = builder.name(name);
        }
        if let Some(agent) = overrides.agent {
            builder = builder.agent(Some(agent));
        }
        if let Some(stack) = overrides.stack {
            builder = builder.stack(Some(stack));
        }
        if let Some(project) = overrides.project {
            builder = builder.project(Some(project));
        }
        if let Some(parent_id) = overrides.parent_id {
            builder = builder.parent_id(Some(parent_id));
        }
        if let Some(dind) = overrides.dind {
            builder = builder.dind(Some(dind));
        }
        if let Some(privileged) = overrides.privileged {
            builder = builder.privileged(Some(privileged));
        }
        if let Some(sudo) = overrides.sudo {
            builder = builder.sudo(Some(sudo));
        }
        if !overrides.devices.is_empty() {
            builder = builder.devices(overrides.devices);
        }
        if let Some(source) = overrides.repo_copy_source {