workflows.SubmitSubtasks

type MySubTask struct {
	Sensor string
	Value  float64
}

type Task struct{}

func (t *Task) Execute(ctx context.Context) error {
	err := workflows.SubmitSubtasks(ctx, 
		[]workflows.Task{
			&MySubTask{
				Sensor: "A",
				Value:  42,
			},
			&MySubTask{
				Sensor: "B",
				Value:  42,
			}
		},
	)
	if err != nil {
		return fmt.Errorf("failed to submit subtasks: %w", err)
	}

	return nil
}

workflows.SubmitSubtasks(
	ctx context.Context,
	tasks []workflows.Task,
	options ...subtask.SubmitOption,
) ([]subtask.FutureTask, error)

Submit multiple subtasks to the runner. Same as SubmitSubtask, but accepts a list of tasks. This function is intended to be used in tasks.

Parameters

[]Task

A list of tasks to submit

[]subtask.SubmitOption

Options for the subtasks

Options

Set dependencies for the tasks

default:"cluster of the runner"

Set the cluster slug of the cluster where the tasks will be executed.

default:"0"

Set the maximum number of retries for the subtasks in case it fails

default:"false"

Mark the subtasks as optional. Optional subtasks will not fail the job if they fail. Tasks that depend on them will still execute even if they failed.

Returns

A list of future tasks that can be used to set dependencies between tasks.

type MySubTask struct {
	Sensor string
	Value  float64
}

type Task struct{}

func (t *Task) Execute(ctx context.Context) error {
	err := workflows.SubmitSubtasks(ctx, 
		[]workflows.Task{
			&MySubTask{
				Sensor: "A",
				Value:  42,
			},
			&MySubTask{
				Sensor: "B",
				Value:  42,
			}
		},
	)
	if err != nil {
		return fmt.Errorf("failed to submit subtasks: %w", err)
	}

	return nil
}

Python

Go

workflows.SubmitSubtasks

Parameters

Options

Returns

​Parameters

​Options

​Returns

Parameters

Options

Returns