lib/dynflow/executors/parallel.rb in dynflow-0.7.5 vs lib/dynflow/executors/parallel.rb in dynflow-0.7.6

@@ -34,11 +34,12 @@
         end
 
         variants Work::Step, Work::Event, Work::Finalize
       end
 
-      PoolDone   = Algebrick.type { fields! work: Work }
-      WorkerDone = Algebrick.type { fields! work: Work, worker: Worker }
+      PoolDone       = Algebrick.type { fields! work: Work }
+      PoolTerminated = Algebrick.atom
+      WorkerDone     = Algebrick.type { fields! work: Work, worker: Worker }
 
       def initialize(world, pool_size = 10)
         super(world)
         @core = Core.new world, pool_size
       end