parameters: (self, notarealarg=None)
docstring: Recuring tasks for installed repositories.
docstring_summary: Recuring tasks for installed repositories.
docstring_tokens: Recuring tasks for installed repositories .
function: async def prosess_queue(self, notarealarg=None):
          """Recuring tasks for installed repositories."""
          if not self.queue.has_pending_tasks:
              self.logger.debug("Nothing in the queue")
              return
          if self.queue.running:
              self.logger.debug("Queue is already running")
              return
  
          can_update = await get_fetch_updates_for(self.github)
          if can_update == 0:
              self.logger.info(
                  "HACS is ratelimited, repository updates will resume later."
              )
          else:
              self.system.status.background_task = True
              self.hass.bus.async_fire("hacs/status", {})
              await self.queue.execute(can_update)
              self.system.status.background_task = False
              self.hass.bus.async_fire("hacs/status", {})
function_tokens: async def prosess_queue ( self , notarealarg = None ) : if not self . queue . has_pending_tasks : self . logger . debug ( "Nothing in the queue" ) return if self . queue . running : self . logger . debug ( "Queue is already running" ) return can_update = await get_fetch_updates_for ( self . github ) if can_update == 0 : self . logger . info ( "HACS is ratelimited, repository updates will resume later." ) else : self . system . status . background_task = True self . hass . bus . async_fire ( "hacs/status" , { } ) await self . queue . execute ( can_update ) self . system . status . background_task = False self . hass . bus . async_fire ( "hacs/status" , { } )