Method: FuncRunner::Application#run

Defined in:

lib/func_runner/application.rb

#run ⇒ Object

# File 'lib/func_runner/application.rb', line 162

def run
  logger.info("Starting Func Runner application...")
  logger.info("Available functions: #{function_registry.keys.join(", ")}") unless function_registry.empty?
  logger.info("No functions registered.") if function_registry.empty?
  @is_running = true

  configure_assistant if config.auto_update && config.assistant_id

  begin
    while @is_running
      message = dequeue_message
      run_result = process_queue_message(message) if message
      submit_function_results(run_result) if run_result
      delete_message(message.id, message.correlation_id) if run_result
      sleep(config.polling_interval)
    end
  rescue Interrupt
    logger.info("Shutting down gracefully...")
    @is_running = false
  end
end