fix: Add support for py310 (#49)

Author: ssbarnea

.github/workflows/tox.yml

@@ -107,28 +107,32 @@ jobs:
         # - windows-latest
         # - windows-2016
         python-version:
-        - 3.6
-        - 3.7
-        - 3.8
-        - 3.9
+        - "3.6"
+        - "3.7"
+        - "3.8"
+        - "3.9"
+        - "3.10"
         include:
         - os: ubuntu-latest
-          python-version: 3.6
+          python-version: "3.6"
           tox_env: py36
         - os: ubuntu-latest
-          python-version: 3.7
+          python-version: "3.7"
           tox_env: py37
         - os: ubuntu-latest
-          python-version: 3.8
+          python-version: "3.8"
           tox_env: py38
         - os: ubuntu-latest
-          python-version: 3.9
+          python-version: "3.9"
           tox_env: py39
+        - os: ubuntu-latest
+          python-version: "3.10"
+          tox_env: py310
         - os: macOS-latest
-          python-version: 3.6
+          python-version: "3.6"
           tox_env: py36
         - os: macOS-latest
-          python-version: 3.9
+          python-version: "3.10"
           tox_env: py39
 
     env:

setup.cfg

@@ -40,6 +40,7 @@ classifiers =
     Programming Language :: Python :: 3.7
     Programming Language :: Python :: 3.8
     Programming Language :: Python :: 3.9
+    Programming Language :: Python :: 3.10
 
     Topic :: System :: Systems Administration
     Topic :: Utilities

src/subprocess_tee/__init__.py

@@ -80,7 +80,7 @@ def tee_func(line: bytes, sink: List[str], pipe: Optional[Any]) -> None:
                 else:
                     print(line_str)
 
-        loop = asyncio.get_event_loop()
+        loop = asyncio.get_event_loop_policy().get_event_loop()
         tasks = []
         if process.stdout:
             tasks.append(
@@ -135,7 +135,7 @@ def run(args: Union[str, List[str]], **kwargs: Any) -> CompletedProcess:
     if kwargs.get("echo", False):
         print(f"COMMAND: {cmd}")
 
-    loop = asyncio.get_event_loop()
+    loop = asyncio.get_event_loop_policy().get_event_loop()
     result = loop.run_until_complete(_stream_subprocess(cmd, **kwargs))
     # we restore original args to mimic subproces.run()
     result.args = args