fix(worker): use new event loop for Python 3.14+

Switches to asyncio.new_event_loop() for Python 3.14 and above, as
asyncio.get_event_loop() is deprecated. Maintains compatibility with
older Python versions by conditionally selecting the event loop method.

Incorporated fix from python-arq#509 by https://github.com/a3lme

Bump version to 0.27.1

Rename to tomfaulkner-arq.

Author: TomFaulkner

HISTORY.rst

@@ -3,6 +3,11 @@
 History
 -------
 
+v0.27.1 (2026-02-21)
+....................
+* Apply 3.14 patch by @Viicos in #515
+* Incorporing fix from https://github.com/python-arq/arq/pull/509 by https://github.com/a3lme
+
 v0.27.0 (2026-01-30)
 ....................
 

README.md

@@ -12,3 +12,6 @@
 Job queues in python with asyncio and redis.
 
 See [documentation](https://arq-docs.helpmanual.io/) for more details.
+
+# TomFaulkner Fork
+Patched support for Python 3.14, bumped version.

arq/version.py

@@ -1,2 +1,2 @@
 # Version here is used for the package version via the `[tool.hatch.version]` section of `pyproject.toml`.
-VERSION = '0.27.0'
+VERSION = '0.27.1'

arq/worker.py

@@ -3,6 +3,7 @@
 import inspect
 import logging
 import signal
+import sys
 from collections.abc import Sequence
 from dataclasses import dataclass
 from datetime import datetime, timedelta, timezone
@@ -267,7 +268,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

pyproject.toml

@@ -5,8 +5,11 @@ build-backend = 'hatchling.build'
 [tool.hatch.version]
 path = 'arq/version.py'
 
+[tool.hatch.build.targets.wheel]
+packages = ["arq"]
+
 [project]
-name = 'arq'
+name = 'tomfaulkner-arq'
 description = 'Job queues in python with asyncio and redis'
 authors = [{name = 'Samuel Colvin', email = 's@muelcolvin.com'}]
 license = { text = 'MIT' }
@@ -29,6 +32,7 @@ classifiers = [
     'Programming Language :: Python :: 3.11',
     'Programming Language :: Python :: 3.12',
     'Programming Language :: Python :: 3.13',
+    'Programming Language :: Python :: 3.14',
     'Topic :: Internet',
     'Topic :: Software Development :: Libraries :: Python Modules',
     'Topic :: System :: Clustering',
@@ -50,11 +54,11 @@ watch = ['watchfiles>=0.16']
 arq = 'arq.cli:cli'
 
 [project.urls]
-Homepage = 'https://github.com/python-arq/arq'
+Homepage = 'https://github.com/TomFaulkner/arq'
 Documentation = 'https://arq-docs.helpmanual.io'
 Funding = 'https://github.com/sponsors/samuelcolvin'
-Source = 'https://github.com/python-arq/arq'
-Changelog = 'https://github.com/python-arq/arq/releases'
+Source = 'https://github.com/TomFaulkner/arq'
+Changelog = 'https://github.com/TomFaulkner/arq/releases'
 
 [dependency-groups]
 testing = [