job

package
v0.19.901 Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2026 License: AGPL-3.0 Imports: 19 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
	QueueClient   *queueclient.Client
}

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-v2 workflow @execution-timeout 1h @task-timeout 1m @task-queue "api" @id-generator WorkflowIDCallback

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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