MCPcopy Create free account
hub / github.com/chekusu/wanman / notifyTaskAssignment

Method notifyTaskAssignment

packages/runtime/src/supervisor.ts:225–241  ·  view source on GitHub ↗
(
    agent: string,
    task: { id: string; title: string; priority: number; description: string; executionProfile?: string },
    from: string,
  )

Source from the content-addressed store, hash-verified

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) => {

Callers 1

handleRpcAsyncMethod · 0.95

Calls 2

infoMethod · 0.80
sendMethod · 0.65

Tested by

no test coverage detected