(taskID, scopeID string)
| 255 | } |
| 256 | |
| 257 | func (rt *AgentTaskRuntime) GetTask(taskID, scopeID string) *AgentTaskRecord { |
| 258 | rt.mu.Lock() |
| 259 | defer rt.mu.Unlock() |
| 260 | record := rt.records[taskID] |
| 261 | if record == nil || record.ParentScopeID != scopeID { |
| 262 | return nil |
| 263 | } |
| 264 | cp := *record |
| 265 | return &cp |
| 266 | } |
| 267 | |
| 268 | func (rt *AgentTaskRuntime) RegisterForegroundTask(taskID, parentTaskID, parentScopeID, workerLabel, description, agentType string) *AgentTaskRecord { |
| 269 | now := nowSeconds() |
no outgoing calls