Skip to content

Commit bdabb81

Browse files
authored
fix: regression with resume (#2666)
1 parent f633589 commit bdabb81

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

metaflow/datastore/flow_datastore.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,8 @@ def get_task_datastores(
167167
if attempt is not None and attempt <= metaflow_config.MAX_ATTEMPTS - 1:
168168
attempt_range = range(attempt + 1) if include_prior else [attempt]
169169
for task_url in task_urls:
170-
task_splits = task_url.split("/")
170+
# task_url can have a trailing slash, so strip this to avoid empty strings in the split
171+
task_splits = task_url.rstrip("/").split("/")
171172
# Usually it is flow, run, step, task (so 4 components) -- if we have a
172173
# fifth one, there is a specific attempt number listed as well.
173174
task_attempt_range = attempt_range

0 commit comments

Comments
 (0)