Sha256: 3583ee752c87d00559a92d73a4dc60512451d5b3fe82c2098c624498f62324f3
Contents?: true
Size: 1.21 KB
Versions: 6
Compression:
Stored size: 1.21 KB
Contents
# frozen_string_literal: true
module Floe
class Workflow
module States
class Fail < Floe::Workflow::State
attr_reader :cause, :error, :cause_path, :error_path
def initialize(workflow, name, payload)
super
@cause = payload["Cause"]
@error = payload["Error"]
@cause_path = Path.new(payload["CausePath"]) if payload["CausePath"]
@error_path = Path.new(payload["ErrorPath"]) if payload["ErrorPath"]
end
def finish(context)
context.next_state = nil
# TODO: support intrinsic functions here
# see https://docs.aws.amazon.com/step-functions/latest/dg/amazon-states-language-fail-state.html
# https://docs.aws.amazon.com/step-functions/latest/dg/amazon-states-language-intrinsic-functions.html#asl-intrsc-func-generic
context.output = {
"Error" => @error_path ? @error_path.value(context, context.input) : error,
"Cause" => @cause_path ? @cause_path.value(context, context.input) : cause
}.compact
super
end
def running?(_)
false
end
def end?
true
end
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems