Contents

require 'vx/common'

module Vx
  module Worker

    class Local

      include Common::Helper::Middlewares

      attr_reader :job

      middlewares do
        use LogJob
        use UpdateJobStatus
        use Timeout
        use StartConnector
        use RunScript
      end

      def initialize(job, _)
        @job = job
      end

      def perform
        env = OpenStruct.new job: job
        run_middlewares(env){ |_| 0 }
      end

    end

  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
vx-worker-0.3.0.pre1	lib/vx/worker/local.rb
vx-worker-0.3.0.pre0	lib/vx/worker/local.rb
vx-worker-0.2.1	lib/vx/worker/local.rb
vx-worker-0.2.0.pre38	lib/vx/worker/local.rb
vx-worker-0.2.0.pre37	lib/vx/worker/local.rb
vx-worker-0.2.0.pre36	lib/vx/worker/local.rb
vx-worker-0.2.0.pre35	lib/vx/worker/local.rb
vx-worker-0.2.0.pre34	lib/vx/worker/local.rb
vx-worker-0.2.0.pre33	lib/vx/worker/local.rb
vx-worker-0.2.0.pre32	lib/vx/worker/local.rb
vx-worker-0.2.0.pre31	lib/vx/worker/local.rb
vx-worker-0.2.0.pre30	lib/vx/worker/local.rb
vx-worker-0.2.0.pre29	lib/vx/worker/local.rb
vx-worker-0.2.0.pre28	lib/vx/worker/local.rb