lib/trailblazer/macro/nested.rb in trailblazer-macro-2.1.13 vs lib/trailblazer/macro/nested.rb in trailblazer-macro-2.1.14
- old
+ new
@@ -111,11 +111,11 @@
# activity. This is needed for {TaskWrap.invoke} and the Debugging API in tracing.
# @private
def self.host_activity_for(activity:)
Activity::TaskWrap.container_activity_for(
activity,
- nodes: [Trailblazer::Activity::NodeAttributes.new(activity.to_s, nil, activity)],
+ id: activity.to_s
)
end
end
@@ -125,19 +125,19 @@
# TODO: allow configuring Output of Nested per internal nested activity, e.g.
# step Nested(.., Id3Tag => {Output(:invalid_metadata) => ...}
# this will help when semantics overlap.
#
def self.Static(decider, id:, auto_wire:)
- decider_outputs = auto_wire.collect do |activity|
+ decider_connectors = auto_wire.collect do |activity|
[Activity::Railway.Output(activity, "decision:#{activity}"), Activity::Railway.Track(activity)]
end.to_h
_task = Class.new(Macro::Nested) do
step(
{
task: Static.method(:return_route_signal),
id: :route_to_nested_activity, # returns the {nested_activity} signal
- }.merge(decider_outputs)
+ }.merge(decider_connectors)
)
auto_wire.each do |activity|
activity_step = Subprocess(activity)