Contents

# frozen_string_literal: true

module Floe
  class Workflow
    module States
      module ChildWorkflowMixin
        def run_nonblock!(context)
          start(context) unless context.state_started?
          step_nonblock!(context)
          return Errno::EAGAIN unless ready?(context)

          finish(context) if ended?(context)
        end

        def finish(context)
          if success?(context)
            result = each_child_context(context).map(&:output)
            context.output = process_output(context, result)
          else
            error = parse_error(context)
            retry_state!(context, error) || catch_error!(context, error) || fail_workflow!(context, error)
          end

          super
        end

        def ready?(context)
          !context.state_started? || each_child_workflow(context).any? { |wf, ctx| wf.step_nonblock_ready?(ctx) }
        end

        def wait_until(context)
          each_child_workflow(context).filter_map { |wf, ctx| wf.wait_until(ctx) }.min
        end

        def waiting?(context)
          each_child_workflow(context).any? { |wf, ctx| wf.waiting?(ctx) }
        end

        def running?(context)
          !ended?(context)
        end

        def ended?(context)
          each_child_context(context).all?(&:ended?)
        end

        def success?(context)
          each_child_context(context).none?(&:failed?)
        end

        def each_child_context(context)
          context.state[child_context_key].map { |ctx| Context.new(ctx) }
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
floe-0.15.1	lib/floe/workflow/states/child_workflow_mixin.rb