Skip to content

Commit f21d790

Browse files
committed
fixes #26
1 parent dad9628 commit f21d790

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

pipeline/src/base.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,18 @@ def _resolve_links(self, node_lookup):
152152
if isinstance(value, Link):
153153
resolved_value = node_lookup[value.identifier]
154154
setattr(self, property.name, resolved_value)
155+
elif hasattr(value, "_resolve_links"):
156+
value._resolve_links(node_lookup)
157+
elif isinstance(value, (tuple, list)):
158+
resolved_values = []
159+
for item in value:
160+
if isinstance(item, Link):
161+
resolved_values.append(node_lookup[item.identifier])
162+
else:
163+
resolved_values.append(item)
164+
if hasattr(item, "_resolve_links"):
165+
item._resolve_links(node_lookup)
166+
setattr(self, property.name, resolved_values)
155167

156168

157169
class LinkedMetadata(Node):

0 commit comments

Comments
 (0)