Method run

src/server/mod.rs:84–130

Start the server and process tasks

(&self)

    /// Start the server and process tasks
    pub async fn run(&self) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
        // Check if server is already running
        if self.lifecycle.is_server_running() {
            return Err("Server is already running".into());
        }

        // Write PID file
        self.lifecycle.write_pid()?;

        self.emit(ServerEvent::StatusMessage(format!(
            "tsk server started (PID {})",
            std::process::id()
        )));

        // Start the task scheduler in the background
        let scheduler = self.scheduler.clone();
        let workers = self.workers;
        let event_sender_clone = self.event_sender.clone();
        let scheduler_handle = tokio::spawn(async move {
            if let Err(e) = scheduler.lock().await.start(workers).await {
                crate::tui::events::emit_or_print(
                    &event_sender_clone,
                    ServerEvent::WarningMessage(format!("Scheduler error: {e}")),
                );
            }
        });
        *self.scheduler_handle.lock().await = Some(scheduler_handle);

        // Wait for the quit signal from the scheduler (quit-when-done mode)
        self.quit_signal.notified().await;
        self.emit(ServerEvent::StatusMessage(
            "Received quit signal from scheduler...".to_string(),
        ));

        // Wait for the scheduler task to finish its cleanup
        if let Some(handle) = self.scheduler_handle.lock().await.take() {
            let _ = handle.await;
        }

        // Clean up server resources
        self.lifecycle.cleanup()?;

        // Ensure terminal title is restored
        self.app_context.terminal_operations().restore_title();

        Ok(())
    }

    /// Perform graceful shutdown: kill managed containers, drain pool, mark tasks cancelled, cleanup.
    ///