Skip to content

Commit

Permalink
doc compute strategy
Browse files Browse the repository at this point in the history
Signed-off-by: Eric Liang <[email protected]>
  • Loading branch information
ericl committed Nov 11, 2022
1 parent cdf4adc commit ed36a06
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions python/ray/data/_internal/execution/bulk_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,11 @@
def _naive_task_execute(
inputs: List[RefBundle], op: OneToOneOperator
) -> List[RefBundle]:
"""Naively execute a 1:1 operation using Ray tasks.
TODO: This should be reconciled with ComputeStrategy.
"""

@ray.remote(num_returns=2)
def transform_one(block: Block) -> (Block, BlockMetadata):
[out] = list(op.execute_one([block], {}))
Expand Down

0 comments on commit ed36a06

Please sign in to comment.