Method enqueue

src/crates/execution/agent-runtime/src/scheduler.rs:265–290

(
        &self,
        session_id: &str,
        turn: T,
        priority: DialogQueuePriority,
    )

    }

    pub fn enqueue(
        &self,
        session_id: &str,
        turn: T,
        priority: DialogQueuePriority,
    ) -> Result<usize, DialogTurnQueueError> {
        let mut queue = self.inner.entry(session_id.to_string()).or_default();
        if queue.len() >= self.max_depth {
            return Err(DialogTurnQueueError::Full {
                session_id: session_id.to_string(),
                max_depth: self.max_depth,
            });
        }

        let queued = QueuedDialogTurn { priority, turn };
        let insert_at = queue
            .iter()
            .position(|existing| existing.priority < queued.priority);
        if let Some(index) = insert_at {
            queue.insert(index, queued);
        } else {
            queue.push_back(queued);
        }

        Ok(queue.len())
    }

    pub fn clear(&self, session_id: &str) -> usize {
        self.inner