class Cadence::ExecutionOptions

Attributes

domain[R]
headers[R]
name[R]
retry_policy[R]
task_list[R]
timeouts[R]

Public Class Methods

new(object, options = {}) click to toggle source
# File lib/cadence/execution_options.rb, line 7
def initialize(object, options = {})
  @name = options[:name] || object.to_s
  @domain = options[:domain]
  @task_list = options[:task_list]
  @retry_policy = options[:retry_policy]
  @cron_schedule = options[:cron_schedule]
  @timeouts = options[:timeouts] || {}
  @headers = options[:headers] || {}

  if object.singleton_class.included_modules.include?(Concerns::Executable)
    @domain ||= object.domain
    @task_list ||= object.task_list
    @retry_policy ||= object.retry_policy
    @timeouts = object.timeouts.merge(@timeouts) if object.timeouts
    @headers = object.headers.merge(@headers) if object.headers
  end

  @domain ||= Cadence.configuration.domain
  @task_list ||= Cadence.configuration.task_list
  @timeouts = Cadence.configuration.timeouts.merge(@timeouts)
  @headers = Cadence.configuration.headers.merge(@headers)

  freeze
end