From 1d7fd54a9baf750e82bd6997c157e39475f0f160 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 29 Jan 2024 16:32:25 +0000 Subject: [PATCH] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- aiojobs/__init__.py | 1 + aiojobs/_scheduler.py | 6 +++--- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/aiojobs/__init__.py b/aiojobs/__init__.py index f4ebab45..0a77ae89 100644 --- a/aiojobs/__init__.py +++ b/aiojobs/__init__.py @@ -4,6 +4,7 @@ asyncio applications. """ + import warnings from typing import Optional diff --git a/aiojobs/_scheduler.py b/aiojobs/_scheduler.py index d7d08cef..3a938c0c 100644 --- a/aiojobs/_scheduler.py +++ b/aiojobs/_scheduler.py @@ -36,9 +36,9 @@ def __init__( self._close_timeout = close_timeout self._limit = limit self._exception_handler = exception_handler - self._failed_tasks: asyncio.Queue[ - Optional[asyncio.Task[object]] - ] = asyncio.Queue() + self._failed_tasks: asyncio.Queue[Optional[asyncio.Task[object]]] = ( + asyncio.Queue() + ) self._failed_task = asyncio.create_task(self._wait_failed()) self._pending: asyncio.Queue[Job[object]] = asyncio.Queue(maxsize=pending_limit) self._closed = False