Module: Conductor::Worker

Defined in:
lib/conductor/worker/worker.rb,
lib/conductor/worker/task_runner.rb,
lib/conductor/worker/task_context.rb,
lib/conductor/worker/task_handler.rb,
lib/conductor/worker/worker_config.rb,
lib/conductor/worker/fiber_executor.rb,
lib/conductor/worker/worker_registry.rb,
lib/conductor/worker/events/listeners.rb,
lib/conductor/worker/task_in_progress.rb,
lib/conductor/worker/events/http_events.rb,
lib/conductor/worker/ractor_task_runner.rb,
lib/conductor/worker/events/conductor_event.rb,
lib/conductor/worker/events/workflow_events.rb,
lib/conductor/worker/events/global_dispatcher.rb,
lib/conductor/worker/events/listener_registry.rb,
lib/conductor/worker/events/task_runner_events.rb,
lib/conductor/worker/task_definition_registrar.rb,
lib/conductor/worker/telemetry/metrics_collector.rb,
lib/conductor/worker/events/sync_event_dispatcher.rb,
lib/conductor/worker/telemetry/prometheus_backend.rb

Defined Under Namespace

Modules: Annotatable, AsyncSupport, Events, RactorSupport, Telemetry, WorkerMixin Classes: FiberExecutor, FiberTaskRunner, JsonSchemaGenerator, RactorTaskRunner, TaskContext, TaskDefinitionRegistrar, TaskHandler, TaskInProgress, TaskRunner, Worker, WorkerConfig, WorkerRegistry

Class Method Summary collapse

Class Method Details

.worker_task(task_definition_name, **options) {|task| ... } ⇒ Worker

Module-level worker_task for defining workers at the top level

Parameters:

  • task_definition_name (String) —

    Task definition name

  • options (Hash) —

    Worker options

Yields:

  • (task) —

    Block to execute tasks

Returns:

  • (Worker) —

    The created worker



351
352
353
 
# File 'lib/conductor/worker/worker.rb', line 351

def self.worker_task(task_definition_name, **options, &block)
  Worker.define(task_definition_name, **options, &block)
end