schedulabletask

Documentation

Index

• type DagImpl
  • func (d *DagImpl) GetSchedulableTasks(ctx context.Context, p *spec.Pipeline, tasks []*spec.PipelineTask) ([]*spec.PipelineTask, error)
• type Interface

Types

type DagImpl

type DagImpl struct {
}

func (*DagImpl) GetSchedulableTasks

func (d *DagImpl) GetSchedulableTasks(ctx context.Context, p *spec.Pipeline, tasks []*spec.PipelineTask) ([]*spec.PipelineTask, error)

GetSchedulableTasks return the list of schedulable tasks. tasks in list can be schedule concurrently.

type Interface

type Interface interface {
	GetSchedulableTasks(ctx context.Context, p *spec.Pipeline, tasks []*spec.PipelineTask) ([]*spec.PipelineTask, error)
}