workflow

package

v1.36.1 Latest Latest Go to latest Published: Apr 24, 2026 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hanzoai/tasks

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Library
- func NewLibrary() *Library
- func (l *Library) Components() []*chasm.RegistrableComponent
- func (l *Library) Name() string
type Workflow
- func NewWorkflow(_ chasm.MutableContext, msPointer chasm.MSPointer) *Workflow

Constants ¶

This section is empty.

Variables ¶

View Source

var Module = fx.Module(
	"chasm.lib.workflow",
	fx.Provide(NewLibrary),
	fx.Invoke(func(registry *chasm.Registry, library *Library) error {
		return registry.Register(library)
	}),
)

Functions ¶

This section is empty.

Types ¶

type Library ¶

type Library struct {
	chasm.UnimplementedLibrary
}

func NewLibrary ¶

func NewLibrary() *Library

func (*Library) Components ¶

func (l *Library) Components() []*chasm.RegistrableComponent

func (*Library) Name ¶

func (l *Library) Name() string

type Workflow ¶

type Workflow struct {
	chasm.UnimplementedComponent

	// For now, workflow state is managed by mutable_state_impl, not CHASM engine, leaving it empty as CHASM expects a
	// state object.
	*emptypb.Empty

	// MSPointer is a special in-memory field for accessing the underlying mutable state.
	chasm.MSPointer

	// Callbacks map is used to store the callbacks for the workflow.
	Callbacks chasm.Map[string, *callback.Callback]
}

func NewWorkflow ¶

func NewWorkflow(
	_ chasm.MutableContext,
	msPointer chasm.MSPointer,
) *Workflow

func (*Workflow) AddCompletionCallbacks ¶

func (w *Workflow) AddCompletionCallbacks(
	ctx chasm.MutableContext,
	eventTime *timestamppb.Timestamp,
	requestID string,
	completionCallbacks []*commonpb.Callback,
	maxCallbacksPerWorkflow int,
) error

AddCompletionCallbacks creates completion callbacks using the CHASM implementation. maxCallbacksPerWorkflow is the configured maximum number of callbacks allowed per workflow.

func (*Workflow) GetNexusCompletion ¶

func (w *Workflow) GetNexusCompletion(
	ctx chasm.Context,
	requestID string,
) (nexusrpc.CompleteOperationOptions, error)

func (*Workflow) LifecycleState ¶

func (w *Workflow) LifecycleState(
	_ chasm.Context,
) chasm.LifecycleState

func (*Workflow) ProcessCloseCallbacks ¶

func (w *Workflow) ProcessCloseCallbacks(ctx chasm.MutableContext) error

ProcessCloseCallbacks triggers "WorkflowClosed" callbacks using the CHASM implementation. It iterates through all callbacks and schedules WorkflowClosed ones that are in STANDBY state.

Source Files ¶

View all Source files

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