Durable.Wait.TimeoutWorker (Durable v0.1.0-rc)

View Source

Background worker that enforces timeouts for pending inputs and events.

Periodically checks for timed-out waits and either:

  • Resumes the workflow with the timeout_value (if on_timeout: :resume)
  • Fails the workflow (if on_timeout: :fail)

Summary

Functions

Manually triggers a timeout check.

Returns a specification to start this module under a supervisor.

Starts the timeout worker.

Returns the process name for a given Durable instance.

Functions

check_timeouts(durable_name \\ Durable)

Manually triggers a timeout check.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(opts)

Starts the timeout worker.

Options

  • :config - The Durable config (required)
  • :interval - Check interval in milliseconds (default: 60_000)

worker_name(durable_name)

Returns the process name for a given Durable instance.