(
agent: string,
task: { id: string; title: string; priority: number; description: string; executionProfile?: string },
from: string,
)
| 223 | get tokenTracker(): TokenTracker { return this._tokenTracker } |
| 224 | |
| 225 | private notifyTaskAssignment( |
| 226 | agent: string, |
| 227 | task: { id: string; title: string; priority: number; description: string; executionProfile?: string }, |
| 228 | from: string, |
| 229 | ): void { |
| 230 | if (!this.agents.has(agent)) { |
| 231 | return; |
| 232 | } |
| 233 | this.relay.send(from, agent, 'task_assigned', { |
| 234 | taskId: task.id, |
| 235 | title: task.title, |
| 236 | priority: task.priority, |
| 237 | description: task.description, |
| 238 | executionProfile: task.executionProfile, |
| 239 | }, 'normal'); |
| 240 | log.info('auto-notified agent of task assignment', { agent, taskId: task.id }); |
| 241 | } |
| 242 | |
| 243 | private filterStaleTaskAssignmentMessages(agent: string, messages: AgentMessage[]): AgentMessage[] { |
| 244 | return messages.filter((message) => { |
no test coverage detected