parameters: (self)
return_statement: return False
docstring: Check if Post-processor queue is greater than the number of workers enabled.
          If it is, return True. Else False.
  
          :return:
docstring_summary: Check if Post-processor queue is greater than the number of workers enabled.
          If it is, return True. Else False.
docstring_tokens: Check if Post - processor queue is greater than the number of workers enabled . If it is return True . Else False .
function: 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
function_tokens: 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