Sha256: ac1d00d9907ea917b6fdb1a2a50fd3ca09d736c2711948cac2b7ab57feaf1828
Contents?: true
Size: 1.05 KB
Versions: 4
Compression:
Stored size: 1.05 KB
Contents
require 'fasten/support/state' module Fasten class Task include Fasten::Support::State attr_accessor :name, :after, :shell, :ruby, :worker_class attr_accessor :dependants, :depends, :request, :response, :worker, :run_score, :block def initialize(name:, shell: nil, ruby: nil, block: nil, request: nil, after: nil, worker_class: nil) self.name = name self.shell = shell self.ruby = ruby self.block = block self.request = request self.after = after self.worker_class = worker_class end def marshal_dump [@name, @state, @ini, @fin, @dif, @request, @response, @shell, @ruby, @block&.object_id, @error] end def marshal_load(data) @name, @state, @ini, @fin, @dif, @request, @response, @shell, @ruby, block_id, @error = data @block = ObjectSpace._id2ref block_id if block_id raise "Sorry, unable to get block for task #{self}, please try using threads" if block_id && !@block.is_a?(Proc) end def kind 'task' end def to_s name end end end
Version data entries
4 entries across 4 versions & 1 rubygems
Version | Path |
---|---|
fasten-0.10.0 | lib/fasten/task.rb |
fasten-0.8.8 | lib/fasten/task.rb |
fasten-0.8.6 | lib/fasten/task.rb |
fasten-0.8.4 | lib/fasten/task.rb |