Sha256: 64fb70b8f6323da343ea63cfccea7f1cc1a27f5fea7ee2ee6a852fecd7e1a361
Contents?: true
Size: 304 Bytes
Versions: 25
Compression:
Stored size: 304 Bytes
Contents
# frozen_string_literal: true module Cloudtasker module UniqueJob module Middleware # Client middleware, invoked when jobs are scheduled class Client def call(worker, **_kwargs) Job.new(worker).lock_instance.schedule { yield } end end end end end
Version data entries
25 entries across 25 versions & 1 rubygems