(self)
return False
Check if Post-processor queue is greater than the number of workers enabled.
        If it is, return True. Else False.

        :return:
Check if Post-processor queue is greater than the number of workers enabled.
        If it is, return True. Else False.
Check if Post - processor queue is greater than the number of workers enabled . If it is return True . Else False .
def postprocessor_queue_full(self):
        """
        Check if Post-processor queue is greater than the number of workers enabled.
        If it is, return True. Else False.

        :return:
        """
        frontend_messages = self.data_queues.get('frontend_messages')
        # Use the configured worker count + 1 as the post-processor queue limit
        limit = (int(self.get_worker_count()) + 1)
        # Include a count of all available and busy remote workers for the postprocessor queue limit
        limit += len(self.available_remote_managers)
        limit += len(self.remote_task_manager_threads)
        if len(self.task_queue.list_processed_tasks()) > limit:
            self._log("Postprocessor queue is over {}. Halting feeding workers until it drops.".format(limit), level='warning')
            frontend_messages.update(
                {
                    'id':      'pendingTaskHaltedPostProcessorQueueFull',
                    'type':    'status',
                    'code':    'pendingTaskHaltedPostProcessorQueueFull',
                    'message': '',
                    'timeout': 0
                }
            )
            return True

        # Remove the status notification
        frontend_messages.remove_item('pendingTaskHaltedPostProcessorQueueFull')
        return False
def postprocessor_queue_full ( self ) : frontend_messages = self . data_queues . get ( 'frontend_messages' ) # Use the configured worker count + 1 as the post-processor queue limit limit = ( int ( self . get_worker_count ( ) ) + 1 ) # Include a count of all available and busy remote workers for the postprocessor queue limit limit += len ( self . available_remote_managers ) limit += len ( self . remote_task_manager_threads ) if len ( self . task_queue . list_processed_tasks ( ) ) > limit : self . _log ( "Postprocessor queue is over {}. Halting feeding workers until it drops." . format ( limit ) , level = 'warning' ) frontend_messages . update ( { 'id' : 'pendingTaskHaltedPostProcessorQueueFull' , 'type' : 'status' , 'code' : 'pendingTaskHaltedPostProcessorQueueFull' , 'message' : '' , 'timeout' : 0 } ) return True # Remove the status notification frontend_messages . remove_item ( 'pendingTaskHaltedPostProcessorQueueFull' ) return False