Sha256: bb2d1188d811a057dda9514f23d5f71f3f9f5dff76638323239f276d80425bb7
Contents?: true
Size: 603 Bytes
Versions: 2
Compression:
Stored size: 603 Bytes
Contents
# frozen_string_literal: true module Floe class Workflow module States class Succeed < Floe::Workflow::State attr_reader :input_path, :output_path def initialize(workflow, name, payload) super @input_path = Path.new(payload.fetch("InputPath", "$")) @output_path = Path.new(payload.fetch("OutputPath", "$")) end def end? true # TODO: Handle if this is ending a parallel or map state end private def to_dot_attributes super.merge(:color => "green") end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
floe-0.1.1 | lib/floe/workflow/states/succeed.rb |
floe-0.1.0 | lib/floe/workflow/states/succeed.rb |