Method Set

ai-provider/local/executor.go:55–64

(id string, p *Pipeline)

}

func (m *modelPipeline) Set(id string, p *Pipeline) error {
	_, ok := m.pipelines.Get(id)
	if !ok {
		if m.pipelines.Count() > m.maxSize {
			return fmt.Errorf("pipeline size exceed %d", m.maxSize)
		}
	}
	m.pipelines.Set(id, p)
	return nil
}

func (m *modelPipeline) AddPipeline(id string) (*Pipeline, error) {
	ctx, cancel := context.WithCancel(m.ctx)