lib/kraps/job.rb in kraps-0.9.0 vs lib/kraps/job.rb in kraps-0.10.0

@@ -101,9 +101,27 @@
           )
         end
       end
     end
 
+    def append(other_job, jobs: nil, worker: @worker, before: nil, &block)
+      fresh.tap do |job|
+        job.instance_eval do
+          @steps << Step.new(
+            action: Actions::APPEND,
+            jobs: [jobs, @partitions].compact.min,
+            partitions: @partitions,
+            partitioner: @partitioner,
+            worker: worker,
+            before: before,
+            block: block,
+            dependency: other_job,
+            options: { append_step_index: other_job.steps.size - 1 }
+          )
+        end
+      end
+    end
+
     def each_partition(jobs: nil, worker: @worker, before: nil, &block)
       fresh.tap do |job|
         job.instance_eval do
           @steps << Step.new(
             action: Actions::EACH_PARTITION,