code: async def connect(self, next_time=None):
          
          if self.status in can_connect:
              loop = self._loop
              if loop.is_running():
                  self.status = StatusType.connecting
                  await self._connect(next_time)
docs: Connect with store
  
          :return: a coroutine and therefore it must be awaited