23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
# File 'lib/legion/mcp/tools/worker_lifecycle.rb', line 23
def call(worker_id:, to_state:, by:, reason: nil)
log.info('Starting legion.mcp.tools.worker_lifecycle.call')
return error_response('legion-data is not connected') unless data_connected?
worker = Legion::DigitalWorker.find(worker_id: worker_id)
return error_response("Worker not found: #{worker_id}") unless worker
updated = Legion::DigitalWorker::Lifecycle.transition!(worker, to_state: to_state, by: by, reason: reason)
text_response(updated.values)
rescue Legion::DigitalWorker::Lifecycle::InvalidTransition => e
handle_exception(e, level: :warn, operation: 'legion.mcp.tools.worker_lifecycle.call')
log.warn("WorkerLifecycle#call invalid transition: #{e.message}")
error_response("Invalid transition: #{e.message}")
rescue StandardError => e
handle_exception(e, level: :warn, operation: 'legion.mcp.tools.worker_lifecycle.call')
log.warn("WorkerLifecycle#call failed: #{e.message}")
error_response("Lifecycle transition failed: #{e.message}")
end
|