DelayedWorker

# == Schema Information

# Table name: test_delayed_workers

# some_column                   :string(255)
# delayed_worker_disabled       :boolean          default(TRUE)
# delayed_worker_scheduled_at   :datetime

class TestDelayedWorkerController < ActionController::Base
  def update_column
    record = TestDelayedWorker.find(params[:id])
    
    add_job_into_delayed_worker job_name: 'update some_column value' do
    # all code in block will be run asynchronous in delayed worker.
    # do heavy task here, e.g. invoke exteral API or do heavy SQL query
    # ...
    
    update(some_column: 'new_value') # can use any activerecord object method here to update record
    # ...
    # You can outout log to `log/delayed_worker.log` with following code:
    # DelayedWorker::Logger.logger.info 'logger something'
    end
  end
end

class TestDelayedWorkerController < ActionController::Base
  def update_column
  record = TestDelayedWorker.find(params[:id], scheduled_at: 3600)

    add_job_into_delayed_worker job_name: 'update some_column value' do
      update(some_column: 'new_value') # can use any activerecord object method here to update record
    end
  end
end

class TestDelayedWorkerController < ActionController::Base
 def update_column
   id = params[:id]
   new_params = {some_column: params[:some_column]}
   
   # we must use `params: {key1: value1, key2...}` to pass local variable into block.
   add_job_into_delayed_worker job_name: 'update some column value use params in controller', subject_id: id, params: new_params do
     record = TestDelayedWorker.find(subject_id)
     record.update(some_column: params[:some_column]) # get passed in value with: params[:some_key] or params['some_key']
   end
 end
end

class SimpleDelayedWorker
  include DelayedWorker::Concern
  
  def some_method
    add_job_into_delayed_worker job_name: 'simple delayed worker', time: 10 do
      print 'run asynchronous after 10 seconds'
    end
  end
end