Class: Temporal::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/temporal/client.rb,
lib/temporal/client/implementation.rb,
lib/temporal/client/workflow_handle.rb

Defined Under Namespace

Classes: Implementation, WorkflowHandle

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(connection, namespace, interceptors: [], payload_converter: Temporal::PayloadConverter::DEFAULT, payload_codecs: [], failure_converter: Temporal::FailureConverter::DEFAULT) ⇒ Client

Create a Temporal client from a connection.

Parameters:

See Also:



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
 
# File 'lib/temporal/client.rb', line 34

def initialize(
  connection,
  namespace,
  interceptors: [],
  payload_converter: Temporal::PayloadConverter::DEFAULT,
  payload_codecs: [],
  failure_converter: Temporal::FailureConverter::DEFAULT
)
  @namespace = namespace
  data_converter = DataConverter.new(
    payload_converter: payload_converter,
    payload_codecs: payload_codecs,
    failure_converter: failure_converter,
  )
  @implementation = Client::Implementation.new(connection, namespace, data_converter, interceptors)
end

Instance Attribute Details

#namespace ⇒ String (readonly)

Returns Namespace used for client calls.

Returns:

  • (String) —

    Namespace used for client calls.



15
16
17
 
# File 'lib/temporal/client.rb', line 15

def namespace
  @namespace
end

Instance Method Details

#start_workflow(workflow, *args, id:, task_queue:, execution_timeout: nil, run_timeout: nil, task_timeout: nil, id_reuse_policy: Workflow::IDReusePolicy::ALLOW_DUPLICATE, retry_policy: nil, cron_schedule: '', memo: nil, search_attributes: nil, start_signal: nil, start_signal_args: [], rpc_metadata: {}, rpc_timeout: nil) ⇒ Temporal::Client::WorkflowHandle

Start a workflow and return its handle.

Parameters:

  • workflow (String) —

    Name of the workflow.

  • args (any) —

    Arguments to the workflow.

  • id (String) —

    Unique identifier for the workflow execution.

  • task_queue (String, Symbol) —

    Task queue to run the workflow on.

  • execution_timeout (Integer) (defaults to: nil) —

    Total workflow execution timeout including retries and continue as new.

  • run_timeout (Integer) (defaults to: nil) —

    Timeout of a single workflow run.

  • task_timeout (Integer) (defaults to: nil) —

    Timeout of a single workflow task.

  • id_reuse_policy (Symbol) (defaults to: Workflow::IDReusePolicy::ALLOW_DUPLICATE) —

    How already-existing IDs are treated. Refer to Workflow::IDReusePolicy for the list of allowed values.

  • retry_policy (Temporal::RetryPolicy) (defaults to: nil) —

    Retry policy for the workflow. See RetryPolicy.

  • cron_schedule (String) (defaults to: '') —

    See docs.temporal.io/docs/content/what-is-a-temporal-cron-job.

  • memo (Hash<String, any>) (defaults to: nil) —

    Memo for the workflow.

  • search_attributes (Hash<String, any>) (defaults to: nil) —

    Search attributes for the workflow.

  • start_signal (String, Symbol) (defaults to: nil) —

    If present, this signal is sent as signal-with-start instead of traditional workflow start.

  • start_signal_args (Array<any>) (defaults to: []) —

    Arguments for start_signal if ‘:start_signal` present.

  • rpc_metadata (Hash<String, String>) (defaults to: {}) —

    Headers used on the RPC call. Keys here override client-level RPC metadata keys.

  • rpc_timeout (Integer) (defaults to: nil) —

    Optional RPC deadline to set for the RPC call.

Returns:

Raises:



79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
 
# File 'lib/temporal/client.rb', line 79

def start_workflow( # rubocop:disable Metrics/ParameterLists
  workflow,
  *args,
  id:,
  task_queue:,
  execution_timeout: nil,
  run_timeout: nil,
  task_timeout: nil,
  id_reuse_policy: Workflow::IDReusePolicy::ALLOW_DUPLICATE,
  retry_policy: nil,
  cron_schedule: '',
  memo: nil,
  search_attributes: nil,
  start_signal: nil,
  start_signal_args: [],
  rpc_metadata: {},
  rpc_timeout: nil
)
  input = Interceptor::Client::StartWorkflowInput.new(
    workflow: workflow,
    args: args,
    id: id,
    task_queue: task_queue,
    execution_timeout: execution_timeout,
    run_timeout: run_timeout,
    task_timeout: task_timeout,
    id_reuse_policy: id_reuse_policy,
    retry_policy: retry_policy,
    cron_schedule: cron_schedule,
    memo: memo,
    search_attributes: search_attributes,
    headers: {},
    start_signal: start_signal,
    start_signal_args: start_signal_args,
    rpc_metadata: rpc_metadata,
    rpc_timeout: rpc_timeout,
  )

  implementation.start_workflow(input)
end

#workflow_handle(id, run_id: nil, first_execution_run_id: nil) ⇒ Temporal::Client::WorkflowHandle

Get a workflow handle to an existing workflow by its ID.

Parameters:

  • id (String) —

    Workflow ID to get a handle to.

  • run_id (String, nil) (defaults to: nil) —

    Run ID that will be used for all calls. If omitted, the latest run for a given workflow ID will be referenced.

  • first_execution_run_id (String, nil) (defaults to: nil) —

    A run ID referencing the first workflow execution in a chain. Workflows are chained when using continue-as-new, retries (as permitted by the retry policy) or cron executions.

Returns:



130
131
132
133
134
135
136
137
138
 
# File 'lib/temporal/client.rb', line 130

def workflow_handle(id, run_id: nil, first_execution_run_id: nil)
  WorkflowHandle.new(
    implementation,
    id,
    run_id: run_id,
    result_run_id: run_id,
    first_execution_run_id: first_execution_run_id,
  )
end