Module: Conductor::Worker::WorkerMixin::ClassMethods

Defined in:
lib/conductor/worker/worker.rb

Instance Method Summary collapse

Instance Method Details

#task_definition_name ⇒ String

Returns Task definition name.

Returns:

  • (String) —

    Task definition name



253
254
255
 
# File 'lib/conductor/worker/worker.rb', line 253

def task_definition_name
  @task_definition_name
end

#task_type ⇒ Object

Alias for compatibility



258
259
260
 
# File 'lib/conductor/worker/worker.rb', line 258

def task_type
  @task_definition_name
end

#worker_options ⇒ Hash

Returns Worker options.

Returns:

  • (Hash) —

    Worker options



263
264
265
 
# File 'lib/conductor/worker/worker.rb', line 263

def worker_options
  @worker_options || {}
end

#worker_task(task_definition_name, **options) ⇒ Object

Define a worker for a specific task type

Parameters:

  • task_definition_name (String) —

    Task definition name

  • options (Hash) —

    Worker options



242
243
244
245
246
247
248
249
250
 
# File 'lib/conductor/worker/worker.rb', line 242

def worker_task(task_definition_name, **options)
  @task_definition_name = task_definition_name
  @worker_options = options

  # Apply defaults
  Worker::DEFAULTS.each do |key, default|
    instance_variable_set("@#{key}", options.fetch(key, default))
  end
end