lib/acidic_job/run.rb in acidic_job-1.0.0.beta.6 vs lib/acidic_job/run.rb in acidic_job-1.0.0.beta.7

@@ -171,9 +171,13 @@
 
       def next_step_name
         current_step_hash.fetch("then")
       end
 
+      def current_step_awaits
+        current_step_hash.fetch("awaits", []) || []
+      end
+
       def next_step_finishes?
         next_step_name.to_s == FINISHED_RECOVERY_POINT
       end
 
       def current_step_finished?