diff --git a/allenact/algorithms/onpolicy_sync/vector_sampled_tasks.py b/allenact/algorithms/onpolicy_sync/vector_sampled_tasks.py index 11d27e50..2ae2b019 100644 --- a/allenact/algorithms/onpolicy_sync/vector_sampled_tasks.py +++ b/allenact/algorithms/onpolicy_sync/vector_sampled_tasks.py @@ -682,17 +682,6 @@ def mp_ctx(self): """ return self._mp_ctx - # def next_task(self, **kwargs): - # if "force_advance_scene" in kwargs: - # # TODO just send it to the first thread in each process if in multithreading - # self.command_at() - # # TODO just send it to all the rest of subprocesses in each process (this sucks big time) - # return self.command( - # commands=NEXT_TASK_COMMAND, data_list=[kwargs] * self.num_unpaused_tasks - # ) - # - # return super().next_task(**kwargs) - @staticmethod def _task_sampling_loop_worker( worker_id: Union[int, str],