Method ShouldExtract

agent/memory_extraction.go:73–85

(state *AgentState)

func (c *ExtractionController) Schedule(_ context.Context, state *AgentState, _ string) bool {
	if !c.ShouldExtract(state) {
		return false
	}
	payload := c.incrementalFabricContext(state)
	if len(payload.Messages) == 0 {
		c.advanceFabricCursor(payload)
		return false
	}

	c.mu.Lock()
	if c.currentRunning {
		c.pendingContext = payload
		c.mu.Unlock()
		return false
	}
	runCtx, cancel := context.WithCancel(context.Background())