interrupt

README

Interrupt

This is a simple example of a workflow that uses an ExternalEvent to trigger an Interrupt Handler.

Start the Task Worker

We have two TaskDef's and thus two Task Functions. Note that worker/main.go kicks off two threads, one for each Task Worker.

go run ./interrupt/worker

Register the WfSpec

In another terminal, run:

go run ./interrupt/deploy

Run a WfRun

Let's run the WfRun:

lhctl run interrupt-example

Note the wfRunId. The WfRun will be sleeping for 15 seconds, in which time you can add to the tally by sending an interrupt event to it:

lhctl postEvent <wfRunId> update-tally INT 10

Then you can see all of the ThreadRuns in the WfRun by:

lhctl get wfRun <wfRunId>

And you can see the final tally via:

lhctl get variable <wfRunId> 0 tally

Documentation

Index

• func ChildFooTask(interruptInput int) string
• func InterruptWorkflow(thread *wflib.ThreadBuilder)
• func ReportTheResult(input int) string

Functions

func ChildFooTask

func ChildFooTask(interruptInput int) string

func InterruptWorkflow

func InterruptWorkflow(thread *wflib.ThreadBuilder)

func ReportTheResult

func ReportTheResult(input int) string