Skip to content

Commit

Permalink
render data futures with tid not repr
Browse files Browse the repository at this point in the history
  • Loading branch information
benclifford committed Jan 13, 2025
1 parent 43196e0 commit 4ece649
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions parsl/dataflow/dflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -1424,12 +1424,13 @@ def default_std_autopath(self, taskrecord, kw):
kw))

def render_future_description(self, dep: Future) -> str:
"""Renders a description of the future in the context of the current
DFK: if the future is an AppFuture associated with the current DFK,
render a task ID, otherwise use the object's repr.
"""Renders a description of the future in the context of the
current DFK.
"""
if isinstance(dep, AppFuture) and dep.task_record['dfk'] == self:
tid = "task " + repr(dep.task_record['id'])
elif isinstance(dep, DataFuture):
tid = "DataFuture from task " + repr(dep.tid)
else:
tid = repr(dep)
return tid
Expand Down

0 comments on commit 4ece649

Please sign in to comment.