Contents

# frozen_string_literal: true

module Cloudtasker
  module UniqueJob
    module Middleware
      # TODO: kwargs to job otherwise it won't get the time_at
      # Client middleware, invoked when jobs are scheduled
      class Client
        def call(worker, _opts = {})
          Job.new(worker).lock_instance.schedule { yield }
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
cloudtasker-0.13.2	lib/cloudtasker/unique_job/middleware/client.rb
cloudtasker-0.13.1	lib/cloudtasker/unique_job/middleware/client.rb
cloudtasker-0.13.0	lib/cloudtasker/unique_job/middleware/client.rb
cloudtasker-0.13.rc2	lib/cloudtasker/unique_job/middleware/client.rb
cloudtasker-0.13.rc1	lib/cloudtasker/unique_job/middleware/client.rb