Skip to content

Commit 45fb99f

Browse files
committed
add an example for actor_to_operation_nodes
Signed-off-by: Kai-Hsun Chen <kaihsun@anyscale.com>
1 parent b125f69 commit 45fb99f

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

python/ray/dag/compiled_dag_node.py

+11-3
Original file line numberDiff line numberDiff line change
@@ -1159,9 +1159,17 @@ def _generate_dag_operation_graph_node(
11591159
A dictionary that maps an actor handle to a list of lists of
11601160
_DAGOperationGraphNode. For the same actor, the index of the
11611161
outer list corresponds to the index of the ExecutableTask in
1162-
the list of `executable_tasks` in `actor_to_executable_tasks`.
1163-
In the inner list, the order of operations is READ, COMPUTE,
1164-
and WRITE.
1162+
the list of `executable_tasks` in `actor_to_executable_tasks`,
1163+
i.e. `local_idx`. In the inner list, the order of operations
1164+
is READ, COMPUTE, and WRITE.
1165+
1166+
Example:
1167+
{
1168+
actor1: [
1169+
[READ COMPUTE WRITE] # local_idx 0
1170+
[READ COMPUTE WRITE] # local_idx 1
1171+
]
1172+
}
11651173
"""
11661174
assert self.idx_to_task
11671175
assert self.actor_to_executable_tasks

0 commit comments

Comments
 (0)