Module: Legion::LLM::Pipeline::Steps::PostResponse

Includes:

Legion::Logging::Helper

Included in:

Executor

Defined in:

lib/legion/llm/pipeline/steps/post_response.rb

Instance Method Summary

• #step_post_response ⇒ Object

Instance Method Details

#step_post_response ⇒ Object

# File 'lib/legion/llm/pipeline/steps/post_response.rb', line 12

def step_post_response
  response = current_response

  audit_event = AuditPublisher.publish(request: @request, response: response)

  Legion::Gaia::AuditObserver.instance.process_event(audit_event) if defined?(Legion::Gaia::AuditObserver) && audit_event

  @timeline.record(
    category: :audit, key: 'audit:publish',
    direction: :outbound, detail: 'published to llm.audit',
    from: 'pipeline', to: 'llm.audit'
  )
rescue StandardError => e
  @warnings << "post_response error: #{e.message}"
  handle_exception(e, level: :warn, operation: 'llm.pipeline.steps.post_response')
end