lib/pmux/job.rb in pmux-0.1.1 vs lib/pmux/job.rb in pmux-0.1.2

@@ -5,10 +5,11 @@
     extend Forwardable
     def_delegators :@h, :[], :[]=, :delete
     attr_reader :tasks, :num_t, :num_r
     attr_reader :taskhash
     attr_reader :reducers
+    attr_reader :failed
 
     def initialize params, files
       @params = params
       @files = files
 
@@ -18,13 +19,14 @@
 
       @taskhash = {}
       @done_taskhash = {}
       @tasks = mk_tasks files
       @num_t = @tasks.size + @num_r
-      @h = {:start_time=>Time.now,
+      @h = {:job_started_at=>Time.now,
         :map_tasks=>@tasks.size, :reduce_tasks=>@num_r,
       }
+      @failed = false
     end
 
     def mk_tasks files
       job_id = self.id
       files.map {|file|
@@ -81,21 +83,26 @@
 
     def completed?
       @taskhash.empty?
     end
 
+    def set_failed
+      @taskhash.clear
+      @failed = true
+    end
+
     def to_jlheader
       h = {:id=>id, :files_first=>@files.first, :tasksize=>@tasks.size,
         :params=>@params,
-        :start_time=>@h[:start_time],
+        :invoked_at=>@h[:invoked_at], :job_started_at=>@h[:job_started_at],
         :map_tasks=>@h[:map_tasks], :reduce_tasks=>@h[:reduce_tasks],
         :storage_name=>@params[:storage_name],
         :mapper=>@params[:mapper], :reducer=>@params[:reducer],
         :num_r=>@params[:num_r],
       }
     end
 
     def to_jlfooter
-      h = {:end_time=>@h[:end_time]}
+      h = {:job_finished_at=>@h[:job_finished_at]}
     end
   end
 end