azure-batch/azure/batch/custom/patch.py
def task_collection_thread_handler(self, results_queue):
        """Main method for worker to run

        Pops a chunk of tasks off the collection of pending tasks to be added and submits them to be added.

        :param collections.deque results_queue: Queue for worker to output results to
        """
        # Add tasks until either we run out or we run into an unexpected error
        while self.tasks_to_add and not self.errors:
            max_tasks = self._max_tasks_per_request  # local copy
            chunk_tasks_to_add = []
            with self._pending_queue_lock:
                while len(chunk_tasks_to_add) < max_tasks and self.tasks_to_add:
                    chunk_tasks_to_add.append(self.tasks_to_add.pop())

            if chunk_tasks_to_add:
                self._bulk_add_tasks(results_queue, chunk_tasks_to_add)
def task_collection_thread_handler(self, results_queue):
        # Add tasks until either we run out or we run into an unexpected error
        while self.tasks_to_add and not self.errors:
            max_tasks = self._max_tasks_per_request  # local copy
            chunk_tasks_to_add = []
            with self._pending_queue_lock:
                while len(chunk_tasks_to_add) < max_tasks and self.tasks_to_add:
                    chunk_tasks_to_add.append(self.tasks_to_add.pop())

            if chunk_tasks_to_add:
                self._bulk_add_tasks(results_queue, chunk_tasks_to_add)
def task_collection_thread_handler ( self , results_queue ) : # Add tasks until either we run out or we run into an unexpected error while self . tasks_to_add and not self . errors : max_tasks = self . _max_tasks_per_request # local copy chunk_tasks_to_add = [ ] with self . _pending_queue_lock : while len ( chunk_tasks_to_add ) < max_tasks and self . tasks_to_add : chunk_tasks_to_add . append ( self . tasks_to_add . pop ( ) ) if chunk_tasks_to_add : self . _bulk_add_tasks ( results_queue , chunk_tasks_to_add )
Main method for worker to run

        Pops a chunk of tasks off the collection of pending tasks to be added and submits them to be added.

        :param collections.deque results_queue: Queue for worker to output results to
Main method for worker to run