Skip to content

Commit 8e395de

Browse files
committed
Ignore foreach_values in merge artifacts
1 parent d95e7b6 commit 8e395de

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

metaflow/flowspec.py

+5-1
Original file line numberDiff line numberDiff line change
@@ -419,6 +419,8 @@ def merge_artifacts(
419419
This exception is thrown in case an artifact specified in `include` cannot
420420
be found.
421421
"""
422+
INTERNAL_ARTIFACTS_SET = set(["_foreach_values"])
423+
422424
include = include or []
423425
exclude = exclude or []
424426
node = self._graph[self._current_step]
@@ -446,7 +448,9 @@ def merge_artifacts(
446448
available_vars = (
447449
(var, sha)
448450
for var, sha in inp._datastore.items()
449-
if (var not in exclude) and (not hasattr(self, var))
451+
if (var not in exclude)
452+
and (not hasattr(self, var))
453+
and (var not in INTERNAL_ARTIFACTS_SET)
450454
)
451455
for var, sha in available_vars:
452456
_, previous_sha = to_merge.setdefault(var, (inp, sha))

0 commit comments

Comments
 (0)