(sink TaskEventSink)
| 131 | firstCompleted bool |
| 132 | } |
| 133 | |
| 134 | func (rt *AgentTaskRuntime) SetTaskEventSink(sink TaskEventSink) { |
| 135 | rt.mu.Lock() |
| 136 | defer rt.mu.Unlock() |
| 137 | rt.taskEventSink = sink |
| 138 | } |
| 139 | |
| 140 | // SetTaskEventObserver installs the durable lifecycle observer. Unlike the UI |
no outgoing calls