Removed unused next_stack specialization

allenai · May 6, 2024 · 19740c1 · 19740c1
1 parent 6247975
commit 19740c1
Showing 1 changed file with 0 additions and 11 deletions.
diff --git 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],