job

package
v0.19.783 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 13, 2026 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WorkflowIDCallback

func WorkflowIDCallback(req *ExecuteJobRequest) string

NOTE(jm): this should not be required once temporal-gen supports passing in a workflow-id via parameter

Types

type ExecuteJobRequest

type ExecuteJobRequest struct {
	RunnerID   string `json:"runner_id" validate:"required"`
	JobID      string `json:"job_id" validate:"required"`
	WorkflowID string `json:"workflow_id" validate:"required"`
}

type Params

type Params struct {
	fx.In

	V             *validator.Validate
	EVClient      teventloop.Client
	MetricsWriter metrics.Writer
}

type Workflows

type Workflows struct {
	// contains filtered or unexported fields
}

this is a workflow that is used to execute a job. It is designed to be reusable outside the context of this namespace, and for all jobs. Thus, it has it's own activities, and other components to allow it to work more effectively.

func New

func New(params Params) (*Workflows, error)

func (*Workflows) ExecuteJob

func (w *Workflows) ExecuteJob(ctx workflow.Context, req *ExecuteJobRequest) (app.RunnerJobStatus, error)

@temporal-gen workflow @execution-timeout 1h @task-timeout 1m @task-queue "api" @id-callback WorkflowIDCallback

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL