module Legion::Extensions::Tasker::Runners::Updater

Public Instance Methods

update_status(task_id:, **opts) click to toggle source
# File lib/legion/extensions/tasker/runners/updater.rb, line 6
def update_status(task_id:, **opts)
  task = Legion::Data::Model::Task[task_id]
  if task.nil? || task.values.nil?
    return { success: false, changed: false, task_id: task_id, message: 'task nil' }
  end

  log.unknown task.class

  update_hash = {}
  %i[status function_args payload results].each do |column|
    next unless opts.key? column

    update_hash[column] = if opts[column].is_a? String
                            opts[column]
                          else
                            to_json opts[column]
                          end
  end
  { success: true, changed: false, task_id: task_id } if update_hash.count.zero?
  task.update(update_hash)

  { success: true, changed: true, task_id: task_id, updates: update_hash }
end