Class: Temporalio::Internal::Bridge::Worker

Inherits:
Object
  • Object
show all
Defined in:
lib/temporalio/internal/bridge/worker.rb

Defined Under Namespace

Classes: CustomSlotSupplier, DeploymentOptions, Options, PollerBehaviorAutoscaling, PollerBehaviorSimpleMaximum, TunerOptions, TunerResourceBasedSlotSupplierOptions, TunerSlotSupplierOptions, WorkerDeploymentVersion

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.finalize_shutdown_all(workers) ⇒ Object 



81
82
83
84
85
86
 
# File 'lib/temporalio/internal/bridge/worker.rb', line 81

def self.finalize_shutdown_all(workers)
  queue = Queue.new
  async_finalize_all(workers, queue)
  result = queue.pop
  raise result if result.is_a?(Exception)
end

Instance Method Details

#complete_activity_task(proto) ⇒ Object 



95
96
97
98
99
100
 
# File 'lib/temporalio/internal/bridge/worker.rb', line 95

def complete_activity_task(proto)
  queue = Queue.new
  async_complete_activity_task(proto.to_proto, queue)
  result = queue.pop
  raise result if result.is_a?(Exception)
end

#complete_activity_task_in_background(proto) ⇒ Object 



102
103
104
105
106
 
# File 'lib/temporalio/internal/bridge/worker.rb', line 102

def complete_activity_task_in_background(proto)
  queue = Queue.new
  # TODO(cretz): Log error on this somehow?
  async_complete_activity_task(proto.to_proto, queue)
end

#validate ⇒ Object 



88
89
90
91
92
93
 
# File 'lib/temporalio/internal/bridge/worker.rb', line 88

def validate
  queue = Queue.new
  async_validate(queue)
  result = queue.pop
  raise result if result.is_a?(Exception)
end