Function waitUntilStatus

test/task_tools_parity_test.go:630–641

(t *testing.T, rt *agent.AgentTaskRuntime, taskID, scopeID, status string)

				block, _ := rawBlock.(map[string]any)
				if strings.Contains(fmt.Sprint(block["text"]), needle) || strings.Contains(fmt.Sprint(block["content"]), needle) {
					return true
				}
			}
		}
	}
	return false
}

func waitUntilStatus(t *testing.T, rt *agent.AgentTaskRuntime, taskID, scopeID, status string) {
	t.Helper()
	deadline := time.Now().Add(3 * time.Second)
	for time.Now().Before(deadline) {
		record := rt.GetTask(taskID, scopeID)
		if record != nil && record.Status == status {
			return