workflows.SubmitSubtask

type MySubTask struct {
	Sensor string
	Value  float64
}

type Task struct{}

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

	return nil
}

type MySubTask struct {
	Sensor string
	Value  float64
}

type Task struct{}

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

	return nil
}

workflows.SubmitSubtask(
	ctx context.Context,
	task workflows.Task,
	options ...subtask.SubmitOption,
) (subtask.FutureTask, error)

Submit a subtask to the runner. This function is intended to be used in tasks.

Parameters

Task

A subtask to submit

[]subtask.SubmitOption

Options for the subtask

Options

Set dependencies for the task

default:"cluster of the runner"

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

default:"0"

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

default:"false"

Mark the subtask as optional. An optional subtask will not fail the job if it fails. Tasks that depend on it will still execute even if it failed.

Returns

A future task 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.SubmitSubtask(ctx, 
		&MySubTask{
			Sensor: "A",
			Value:  42,
		},
	)
	if err != nil {
		return fmt.Errorf("failed to submit subtasks: %w", err)
	}

	return nil
}

Python

Go

workflows.SubmitSubtask

Parameters

Options

Returns