Contents

# typed: true

module UpGush
  module Jobs
    class StopWorkflow
      include Sidekiq::Worker
      extend T::Sig

      sidekiq_options lock: :until_executed, on_conflict: :reject

      def perform(workflow_id)
        wf = Gush::Workflow.find(workflow_id)
        wf.stop!
      rescue Gush::WorkflowNotFound => e
        UpGush::Logger.log.warn("UpGush::Jobs::StopWorkflow: #{e.message}")
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
up_gush-3.0.0.1	lib/up_gush/jobs/stop_workflow.rb