Skip to content

Commit f04e4ea

Browse files
committed
fix :fields issue.
1 parent 5ff56b1 commit f04e4ea

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lib/trailblazer/macro/each.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,7 @@ def self.call((ctx, flow_options), runner:, **circuit_options) # DISCUSS: do we
5656

5757
def self.to_h
5858
container_activity = @state.get(:activity)
59+
pp container_activity
5960
# FIXME: this is needed for a proper {find_path} introspect lookup.
6061
container_activity.to_h.merge(activity: container_activity)
6162
end
@@ -101,9 +102,10 @@ def self.Each(block_activity=nil, dataset_from: nil, item_key: :item, id: Macro.
101102
block_activity,
102103
id: "invoke_block_activity",
103104
# merged into {:config}:
104-
each: true, # mark this activity for {compute_runtime_id}.
105+
each: true, # mark this activity for {compute_runtime_id}.
105106
).merge(
106107
outputs: outputs_from_block_activity,
108+
fields: {task_wrap_extensions: Activity::DSL::Linear::Strategy::INITIAL_TASK_WRAP_EXTENSIONS} # DISCUSS: shouldn't this be part of {:config}? # FIXME: too much knowledge about internals.
107109
)
108110

109111
# FIXME: we can't pass {wrap_static: wrap_static_for_block_activity} into {#container_activity_for}

0 commit comments

Comments
 (0)