childthread

README

Child Threads

This is a simple example of a workflow that launches a Child Thread and waits for its completion.

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 child-thread input "this is the input!"

You can see both ThreadRuns when you inspect the WfRun:

lhctl get wfRun <wfRunId>

Documentation

Index

• func ChildThreadTask(input string) string
• func ChildThreadWorkflow(thread *wflib.ThreadBuilder)
• func ParentThreadTask() string

Functions

func ChildThreadTask

func ChildThreadTask(input string) string

func ChildThreadWorkflow

func ChildThreadWorkflow(thread *wflib.ThreadBuilder)

func ParentThreadTask

func ParentThreadTask() string