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