Workflow for Zebra

[evaachim]

Ideas for implementing a temporal workflow for Zebra.

[evaachim]

Temporal can begin once one of the criteria is met.

• a login occurs

Can check if a given user exists to verify

• a request comes in

Can check the status to verify

• a notification is needed

Based on status / requests

[evaachim]

Preferably, both a synchronous and an asynchronous execution will be used.

[evaachim]

workflow -->
is the criteria met?
--> Yes -->
which one? --> resource requested --> execute activity
--> login occurs --> execute activity

--> No --> don't execute activity

[evaachim]

func Workflow(ctx workflow.Context, resource zebra.Resource, store Zebra.Store) (string, error){

options := workflow.ActivityOptions{
	// some options.
}

execute ActivityLoggedIn
executeActivityRequested

}

func ActivityRequested(ctx context.Context, store zebra.Store, email string) (string, error) {
if requested{
execute RequestedActivitiesInWorkflow
}
}

func ActivityLoggedIn(ctx context.Context, store zebra.Store, email string) (string, error) {
if userLoggedIn{
execute LoginActivitiesInWorkflow
}
}

[evaachim]

Things to consider:

• What worker options should be added?
• Less criteria for triggering temporal and more grouping or more criteria and less grouping?
• How will sync vs async be set up?

[evaachim]

Worker options to consider:

EnableSessionWorker

DeadlockDetectionTimeout

[evaachim]

ActivityOptions not necessarily needed

ClientOptions may be needed

[evaachim]

To consider making async :

1. Send notifications

To consider including in parallel exec logic:

1. Staying Logged in
2. Requests coming in

[evaachim]

Will only use for async situations

[evaachim]

For notification temporal, notification code is needed and may be divided into multiple parts.

[evaachim]

Use temporal with wrapper functions that contain the Zebra logic.

[evaachim]

ActivityOptions not necessarily needed

ClientOptions may be needed

Need a time parameter, to timeout

[evaachim]

Currently using StartToCloseTimeout for the time parameter

[evaachim]

May want to consider adding an additional verification step to distinguish between activities that get triggered, especially when an activity can be subdivided into multiple activities.

[evaachim]

Options for including API on top of temporal

[evaachim]

May consider including a lock/mutex to protect critical sections.

[evaachim]

There can be an interface for all temporal-related functions.

[evaachim]

Temporal should use abstraction

[evaachim]

Set up black-box style logic

[evaachim]

The abstraction can have an initial condition and an exit condition.

[evaachim]

Other things that should exist in the abstraction:

• internal conditions
• options
• potential variable durability for actions

[evaachim]

The initial condition can be one / many. Currently, it is more granular.

[evaachim]

If there is ONE initial condition, it could possibly be the log in. If there are more, each can work as independent conditions.

[evaachim]

Think: How will the exit condition be determined ?

[evaachim]

Some ideas:

• Will there be one initial condition for the workflow?
• Alternatively from above, will there be multiple initial conditions that initiate temporal as a series of interconnected workflows?
• Will there be a single, defined, exit condition?
• Alternatively from above, will there be multiple cases when temporal exits?
• Will there be a single, big workflow?
• Alternatively from above, will there be multiple workflows, with connective conditions?
• Will temporal execute indefinitely
• Alternatively from above, will temporal execute only in certain cases?

[evaachim]

Ideas to consider:

• Will there be a single initiation / exit condition ?

• Alternatively from above, will there be multiple such conditions ?

• Will there be a single workflow with multiple subworkflows / workers?

• Alternatively from above, will there be multiple workflows with connective conditions?

• Will temporal run indefinitely

• Alternatively from above, will temporal only start at certain times?

• How will the exit condition be determined