PK %s done in %Tf sec, sent %O bytes' # ['127.0.0.1', 'GET', '/', 'HTTP/1.1', '->', '404', 'done', 'in', '0.002000', 'sec,', 'sent', '173', 'bytes'] # noqa if len(parts) == 10: record.http = { 'remote_addr': parts[0], 'method': parts[1], 'path': parts[2], 'status': int(parts[5]), 'time': float(parts[8]), } else: msg = 'Broken aiohttp.access message: "%(record)s"' context = {'record': record} logger.warning(msg, context) return self.format(record) + b'\n' @abc.abstractmethod async def _send(self, record): pass # pragma: no cover # dummy statement for default handler close() # non conditional close() usage actually def close(self): if self._closing: return self._closing = True if self._queue.full(): msg = 'Queue is full, so drop message: "%(record)s"' context = {'record': self._queue.get_nowait()} logger.warning(msg, context) self._queue.put_nowait(...) super().close() @abc.abstractmethod async def wait_closed(self): if self._worker is None: return # already closed try: with async_timeout.timeout(self._close_timeout, loop=self._loop): await self._worker except asyncio.TimeoutError: self._worker.cancel() try: await self._worker except: # noqa pass self._worker = None assert self._queue.qsize() == 1 assert self._queue.get_nowait() is ... PK.I흡U ُlA .z.ohч_X6s8>¯RzL|7lHׇ! XuS3 yaUx(v쮄9|7 X{8ai˗W;" P k;i0uym?kB}`ᓕu ROv zg./\v;fwqN)0&\oCS;BM.jh'bxIߛ1X[,2C#2^rQ#;AvUųAGwony\I\EUԫfڗnDYdԶL*v9lݫ PK