Sha256: 57cbd22bd72948b66059713e7fd992c7550797bc236f1acbb5e082536a867f59
Contents?: true
Size: 747 Bytes
Versions: 2
Compression:
Stored size: 747 Bytes
Contents
# frozen_string_literal: true module Floe class Workflow module States class Fail < Floe::Workflow::State attr_reader :cause, :error def initialize(workflow, name, payload) super @cause = payload["Cause"] @error = payload["Error"] end def run!(input) logger.info("Running state: [#{name}] with input [#{input}]") next_state = nil output = input logger.info("Running state: [#{name}] with input [#{input}]...Complete - next state: [#{next_state&.name}]") [next_state, output] end def end? true end def status "errored" end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
floe-0.2.1 | lib/floe/workflow/states/fail.rb |
floe-0.2.0 | lib/floe/workflow/states/fail.rb |