class Temporal::Configuration

Constants

DEFAULT_CONVERTER
DEFAULT_HEADERS
DEFAULT_NAMESPACE
DEFAULT_TASK_QUEUE
DEFAULT_TIMEOUTS

We want an infinite execution timeout for cron schedules and other perpetual workflows. We choose an 10-year execution timeout because that's the maximum the cassandra DB supports, matching the go SDK, see github.com/temporalio/sdk-go/blob/d96130dad3d2bc189bc7626543bd5911cc07ff6d/internal/internal_workflow_testsuite.go#L68

Attributes

client_type[RW]
converter[W]
error_handlers[R]
headers[RW]
host[RW]
logger[RW]
metrics_adapter[RW]
namespace[RW]
port[RW]
task_queue[RW]
timeouts[R]

Public Class Methods

new() click to toggle source
# File lib/temporal/configuration.rb, line 39
def initialize
  @client_type = :grpc
  @logger = Temporal::Logger.new(STDOUT, progname: 'temporal_client')
  @metrics_adapter = MetricsAdapters::Null.new
  @timeouts = DEFAULT_TIMEOUTS
  @namespace = DEFAULT_NAMESPACE
  @task_queue = DEFAULT_TASK_QUEUE
  @headers = DEFAULT_HEADERS
  @converter = DEFAULT_CONVERTER
  @error_handlers = []
end

Public Instance Methods

converter() click to toggle source
# File lib/temporal/configuration.rb, line 67
def converter
  @converter
end
on_error(&block) click to toggle source
# File lib/temporal/configuration.rb, line 51
def on_error(&block)
  @error_handlers << block
end
task_list() click to toggle source
# File lib/temporal/configuration.rb, line 55
def task_list
  @task_queue
end
task_list=(name) click to toggle source
# File lib/temporal/configuration.rb, line 59
def task_list=(name)
  self.task_queue = name
end
timeouts=(new_timeouts) click to toggle source
# File lib/temporal/configuration.rb, line 63
def timeouts=(new_timeouts)
  @timeouts = DEFAULT_TIMEOUTS.merge(new_timeouts)
end