diff --git a/arq/worker.py b/arq/worker.py index f1e613c9..49617624 100644 --- a/arq/worker.py +++ b/arq/worker.py @@ -2,6 +2,7 @@ import contextlib import inspect import logging +import sys import signal from dataclasses import dataclass from datetime import datetime, timedelta, timezone @@ -266,7 +267,7 @@ def __init__( # self.job_tasks holds references the actual jobs running self.job_tasks: Dict[str, asyncio.Task[Any]] = {} self.main_task: Optional[asyncio.Task[None]] = None - self.loop = asyncio.get_event_loop() + self.loop = asyncio.get_event_loop() if sys.version_info < (3, 14) else asyncio.new_event_loop() self.ctx = ctx or {} max_timeout = max(f.timeout_s or self.job_timeout_s for f in self.functions.values()) self.in_progress_timeout_s = (max_timeout or 0) + 10 diff --git a/requirements/linting.txt b/requirements/linting.txt index 873ee0c1..34204613 100644 --- a/requirements/linting.txt +++ b/requirements/linting.txt @@ -4,15 +4,15 @@ # # pip-compile --output-file=requirements/linting.txt --strip-extras requirements/linting.in # -cffi==1.16.0 +cffi==2.0.0 # via cryptography cryptography==42.0.5 # via # types-pyopenssl # types-redis -mypy==1.9.0 +mypy==1.18.2 # via -r requirements/linting.in -mypy-extensions==1.0.0 +mypy-extensions==1.1.0 # via mypy pycparser==2.22 # via cffi @@ -24,5 +24,5 @@ types-pytz==2024.1.0.20240203 # via -r requirements/linting.in types-redis==4.6.0.20240311 # via -r requirements/linting.in -typing-extensions==4.10.0 +typing-extensions==4.15.0 # via mypy diff --git a/requirements/testing.txt b/requirements/testing.txt index 87461fd6..c7f9f322 100644 --- a/requirements/testing.txt +++ b/requirements/testing.txt @@ -36,9 +36,9 @@ packaging==24.0 # pytest pluggy==1.4.0 # via pytest -pydantic==2.6.4 +pydantic==2.12.1 # via -r requirements/testing.in -pydantic-core==2.16.3 +pydantic-core==2.41.3 # via pydantic pygments==2.17.2 # via rich @@ -71,7 +71,7 @@ tomli==2.0.1 # via # coverage # pytest -typing-extensions==4.10.0 +typing-extensions==4.15.0 # via # pydantic # pydantic-core