support python 3.10 (#298)

* support python 3.10, fix #282

* fix get_event_loop usage

Author: samuelcolvin

.github/workflows/ci.yml

@@ -49,7 +49,7 @@ jobs:
       fail-fast: false
       matrix:
         os: [ubuntu]
-        python-version: ['3.7', '3.8', '3.9']
+        python-version: ['3.7', '3.8', '3.9', '3.10']
 
     env:
       PYTHON: ${{ matrix.python-version }}

setup.py

@@ -34,6 +34,7 @@
         'Programming Language :: Python :: 3.7',
         'Programming Language :: Python :: 3.8',
         'Programming Language :: Python :: 3.9',
+        'Programming Language :: Python :: 3.10',
         'Topic :: Internet',
         'Topic :: Software Development :: Libraries :: Python Modules',
         'Topic :: System :: Clustering',

tests/conftest.py

@@ -11,7 +11,6 @@
 
 @pytest.fixture(name='loop')
 def _fix_loop(event_loop):
-    asyncio.set_event_loop(event_loop)
     return event_loop
 
 

tests/test_cli.py

@@ -20,7 +20,8 @@ def test_help():
     assert result.output.startswith('Usage: arq [OPTIONS] WORKER_SETTINGS\n')
 
 
-def test_run(cancel_remaining_task):
+def test_run(cancel_remaining_task, mocker, loop):
+    mocker.patch('asyncio.get_event_loop', lambda: loop)
     runner = CliRunner()
     result = runner.invoke(cli, ['tests.test_cli.WorkerSettings'])
     assert result.exit_code == 0

tests/test_worker.py

@@ -33,15 +33,15 @@ async def fails(ctx):
     raise TypeError('my type error')
 
 
-def test_no_jobs(arq_redis: ArqRedis, loop):
+def test_no_jobs(arq_redis: ArqRedis, loop, mocker):
     class Settings:
         functions = [func(foobar, name='foobar')]
         burst = True
         poll_delay = 0
         queue_read_limit = 10
 
     loop.run_until_complete(arq_redis.enqueue_job('foobar'))
-    asyncio.set_event_loop(loop)
+    mocker.patch('asyncio.get_event_loop', lambda: loop)
     worker = run_worker(Settings)
     assert worker.jobs_complete == 1
     assert str(worker) == '<Worker j_complete=1 j_failed=0 j_retried=0 j_ongoing=0>'