Skip to content

Commit dfb0f1e

Browse files
author
Nissan Pow
committed
fix: inner_join must explicitly store inherited label for outer_join access
In subprocess execution (Dagster), each task's artifact file only contains attributes explicitly assigned during that step — lazy inheritance is not persisted. Without self.label = self.label in inner_join, the outer_join step cannot read label from the inner_join task artifact, causing AttributeError: Flow SplitInBranchFlow has no attribute 'label'.
1 parent db73557 commit dfb0f1e

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

test/ux/core/flows/basic/split_in_branch_flow.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,11 @@ def inner_y(self):
3535
@step
3636
def inner_join(self, inputs):
3737
self.sub_labels = sorted(i.sub_label for i in inputs)
38+
# Explicitly read-and-store inherited 'label' so that outer_join can
39+
# access it from this task's artifact file in subprocess execution.
40+
# Without this, label is lazily inherited during execution but never
41+
# persisted to the artifact store, causing AttributeError downstream.
42+
self.label = self.label
3843
self.next(self.outer_join)
3944

4045
@step

0 commit comments

Comments
 (0)