Class: AcidicJob::LogSubscriber

Inherits:
ActiveSupport::LogSubscriber
  • Object
show all
Defined in:
lib/acidic_job/log_subscriber.rb

Instance Method Summary collapse

Instance Method Details

#define_workflow(event) ⇒ Object 



7
8
9
 
# File 'lib/acidic_job/log_subscriber.rb', line 7

def define_workflow(event)
  debug formatted_event(event, action: "Define workflow", **event.payload.slice("job_class", "job_id"))
end

#initialize_workflow(event) ⇒ Object 



11
12
13
 
# File 'lib/acidic_job/log_subscriber.rb', line 11

def initialize_workflow(event)
  debug formatted_event(event, action: "Initialize workflow", **event.payload.slice("steps"))
end

#perform_step(event) ⇒ Object 



23
24
25
 
# File 'lib/acidic_job/log_subscriber.rb', line 23

def perform_step(event)
  debug formatted_event(event, action: "Perform step", **event.payload)
end

#process_step(event) ⇒ Object 



19
20
21
 
# File 'lib/acidic_job/log_subscriber.rb', line 19

def process_step(event)
  debug formatted_event(event, action: "Process step", **event.payload)
end

#process_workflow(event) ⇒ Object 



15
16
17
 
# File 'lib/acidic_job/log_subscriber.rb', line 15

def process_workflow(event)
  debug formatted_event(event, action: "Process workflow", **event.payload["execution"].slice("id", "recover_to"))
end

#record_entry(event) ⇒ Object 



27
28
29
 
# File 'lib/acidic_job/log_subscriber.rb', line 27

def record_entry(event)
  debug formatted_event(event, action: "Record entry", **event.payload.slice(:step, :action, :timestamp))
end