Method schedule

trinity/explorer/scheduler.py:548–561

Schedule the provided tasks. Args: tasks (`List[Task]`): The tasks to schedule. batch_id (`Union[int, str]`): The id of provided tasks. In most cases, it should be current step number for training tasks and " /<eval_ta

(self, tasks: List[Task], batch_id: Union[int, str])

        self.logger.info("Scheduler stopped")

    def schedule(self, tasks: List[Task], batch_id: Union[int, str]) -> None:
        """Schedule the provided tasks.

        Args:
            tasks (`List[Task]`): The tasks to schedule.
            batch_id (`Union[int, str]`):
                The id of provided tasks. In most cases, it should be current step number for
                training tasks and "<current_step_num>/<eval_taskset_name>" for eval tasks.
        """
        if not tasks:
            return
        self.batch_is_eval_map[batch_id] = tasks[0].is_eval
        self.task_num_map[batch_id] += len(tasks)
        self._split_and_submit_tasks(tasks, batch_id=batch_id)

    def _split_and_submit_tasks(self, tasks: List[Task], batch_id: Union[int, str]) -> None:
        for i, task in enumerate(tasks):