Class: Events::Subscribers::MeleteKickoff

Inherits:
Object
  • Object
show all
Includes:
Events::Subscriber
Defined in:
lib/events/subscribers/melete_kickoff.rb

Overview

Entry subscriber for the Melete stage of the drain pipeline. On Events::StartMelete, enqueues MeleteEnrichmentJob to run skill/goal/workflow preparation asynchronously.

Instance Method Summary collapse

Instance Method Details

#emit(event) ⇒ Object

Parameters:

  • event (Hash) —

    Rails.event notification hash



12
13
14
15
16
17
18
19
20
21
 
# File 'lib/events/subscribers/melete_kickoff.rb', line 12

def emit(event)
  payload = event[:payload]
  session_id = payload[:session_id]
  return unless session_id

  MeleteEnrichmentJob.perform_later(
    session_id,
    pending_message_id: payload[:pending_message_id]
  )
end