temporal.activity — io.github.manetu/temporal-sdk 1.0.3

Methods for defining and invoking activity tasks

defactivity clj macro

(defactivity name params* & body)

Defines a new activity, similar to defn, expecting a 2-arity parameter list and body. Should evaluate to something serializable, which will be available to the invoke caller, or to a core.async channel (See Async Mode below).

Async Mode:

Returning a core.async channel places the activity into Asynchronous mode, where the result may be resolved at a future time by sending a single message on the channel. Sending a Throwable will signal a failure of the activity. Any other value will be serialized and returned to the caller.

Arguments:

• ctx: Context passed through from temporal.client.worker/start
• args: Passed from 'params' of invoke

(defactivity greet-activity
    [ctx {:keys [name] :as args}]
    (str "Hi, " name))

get-heartbeat-details clj

(get-heartbeat-details)

Extracts Heartbeat details from the last failed attempt. This is used in combination with retry options. An Activity Execution could be scheduled with optional temporal.common/retry-options. If an Activity Execution failed then the server would attempt to dispatch another Activity Task to retry the execution according to the retry options. If there were Heartbeat details reported by heartbeat in the last Activity Execution that failed, they would be delivered along with the Activity Task for the next retry attempt and can be extracted by the Activity implementation.

get-info clj

(get-info)

Returns information about the Activity execution

heartbeat clj

(heartbeat details)

Used to notify the Workflow Execution that the Activity Execution is alive.

Arguments:

• details: The details are accessible through get-heartbeat-details on the next Activity Execution retry.

invoke clj

(invoke activity params)

(invoke activity params options)

Invokes 'activity' with 'params' from within a workflow context. Returns a promise that when derefed will resolve to the evaluation of the defactivity once the activity concludes.

Arguments:

• activity: A reference to a symbol registered with defactivity.
• params: Opaque serializable data that will be passed as arguments to the invoked activity
• options: See below.

options map

Value	Description	Type	Default
:cancellation-type	Defines the activity's stub cancellation mode.	See cancellation types below	:try-cancel
:heartbeat-timeout	Heartbeat interval.	Duration
:retry-options	Define how activity is retried in case of failure.	temporal.common/retry-options
:start-to-close-timeout	Maximum time of a single Activity execution attempt.	Duration	3 seconds
:schedule-to-close-timeout	Total time that a workflow is willing to wait for Activity to complete.	Duration
:schedule-to-start-timeout	Time that the Activity Task can stay in the Task Queue before it is picked up by a Worker.	Duration

cancellation types

Value	Description
:try-cancel	In case of activity's scope cancellation send an Activity cancellation request to the server, and report cancellation to the Workflow Execution by causing the activity stub call to fail with CancelledFailure
:abandon	Do not request cancellation of the Activity Execution at all (no request is sent to the server) and immediately report cancellation to the Workflow Execution by causing the activity stub call to fail with CancelledFailure immediately.
:wait-cancellation-completed	Wait for the Activity Execution to confirm any requested cancellation.

(defactivity my-activity
   [ctx {:keys [foo] :as args}]
   ...)

(invoke my-activity {:foo "bar"} {:start-to-close-timeout (Duration/ofSeconds 3))

local-invoke clj

(local-invoke activity params)

(local-invoke activity params options)

Invokes 'activity' with 'params' from within a workflow context as a Local Activity. Returns a promise that when derefed will resolve to the evaluation of the defactivity once the activity concludes.

Arguments:

• activity: A reference to a symbol registered with defactivity.
• params: Opaque serializable data that will be passed as arguments to the invoked activity
• options: See below.

options map

Value	Description	Type	Default
:start-to-close-timeout	Maximum time of a single Activity execution attempt.	Duration
:schedule-to-close-timeout	Total time that a workflow is willing to wait for Activity to complete.	Duration
:retry-options	Define how activity is retried in case of failure.	temporal.common/retry-options
:do-not-include-args	When set to true, the serialized arguments of the local Activity are not included in the Marker Event that stores the local Activity's invocation result.	boolean	false
:local-retry-threshold	Maximum time to retry locally, while keeping the Workflow Task open via a Heartbeat.	Duration

(defactivity my-activity
   [ctx {:keys [foo] :as args}]
   ...)

(local-invoke my-activity {:foo "bar"} {:start-to-close-timeout (Duration/ofSeconds 3))