From 19740c19e8e02ba1b2d446e7f3cdd7ef9eb7d1ff Mon Sep 17 00:00:00 2001 From: Jordi Salvador Date: Mon, 6 May 2024 12:01:26 +0200 Subject: [PATCH] Removed unused next_stack specialization --- .../algorithms/onpolicy_sync/vector_sampled_tasks.py | 11 ----------- 1 file changed, 11 deletions(-) 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],