Class: Joblin::BackgroundTask::BackgroundTaskCallbacks

Inherits:
Object
  • Object
show all
Defined in:
app/models/joblin/background_task.rb

Instance Method Summary collapse

Instance Method Details

#on_complete(status, options) ⇒ Object 



64
65
66
67
68
69
 
# File 'app/models/joblin/background_task.rb', line 64

def on_complete(status, options)
  tracker = BackgroundTask.find(options['id'])
  return if tracker.workflow_state == 'cancelled'

  # tracker.update!(workflow_state: 'completed') if status.success?
end

#on_stagnated(status, options) ⇒ Object 



79
80
81
82
83
 
# File 'app/models/joblin/background_task.rb', line 79

def on_stagnated(status, options)
  tracker = BackgroundTask.find(options['id'])
  tracker.update(workflow_state: 'failed') if tracker.workflow_state != 'cancelled'
  tracker.handle_batch_stagnation
end

#on_success(status, options) ⇒ Object 



71
72
73
74
75
76
77
 
# File 'app/models/joblin/background_task.rb', line 71

def on_success(status, options)
  tracker = BackgroundTask.find(options['id'])
  return if tracker.workflow_state == 'cancelled'
  return if tracker.workflow_state == 'failed'

  tracker.update!(workflow_state: 'completed')
end