python/ray/data/impl/lazy_block_list.py
def _submit_task(
        self, task_idx: int
    ) -> Tuple[ObjectRef[MaybeBlockPartition], ObjectRef[BlockPartitionMetadata]]:
        """Submit the task with index task_idx."""
        stats_actor = _get_or_create_stats_actor()
        if not self._execution_started:
            stats_actor.record_start.remote(self._stats_uuid)
            self._execution_started = True
        task = self._tasks[task_idx]
        return (
            cached_remote_fn(_execute_read_task)
            .options(num_returns=2, **self._remote_args)
            .remote(
                i=task_idx,
                task=task,
                context=DatasetContext.get_current(),
                stats_uuid=self._stats_uuid,
                stats_actor=stats_actor,
            )
        )
Submit the task with index task_idx.
Submit the task with index task_idx.
Submit the task with index task_idx .
def _submit_task(
        self, task_idx: int
    ) -> Tuple[ObjectRef[MaybeBlockPartition], ObjectRef[BlockPartitionMetadata]]:
        stats_actor = _get_or_create_stats_actor()
        if not self._execution_started:
            stats_actor.record_start.remote(self._stats_uuid)
            self._execution_started = True
        task = self._tasks[task_idx]
        return (
            cached_remote_fn(_execute_read_task)
            .options(num_returns=2, **self._remote_args)
            .remote(
                i=task_idx,
                task=task,
                context=DatasetContext.get_current(),
                stats_uuid=self._stats_uuid,
                stats_actor=stats_actor,
            )
        )
def _submit_task ( self , task_idx : int ) -> Tuple [ ObjectRef [ MaybeBlockPartition ] , ObjectRef [ BlockPartitionMetadata ] ] : stats_actor = _get_or_create_stats_actor ( ) if not self . _execution_started : stats_actor . record_start . remote ( self . _stats_uuid ) self . _execution_started = True task = self . _tasks [ task_idx ] return ( cached_remote_fn ( _execute_read_task ) . options ( num_returns = 2 , ** self . _remote_args ) . remote ( i = task_idx , task = task , context = DatasetContext . get_current ( ) , stats_uuid = self . _stats_uuid , stats_actor = stats_actor , ) )
Submit the task with index task_idx.
Submit the task with index task_idx .
"""Submit the task with index task_idx."""
self
task_idx
int