cleanup asyncio windows proactor

Author: scivision

examples/demo.py

@@ -27,7 +27,6 @@
 import asyncio
 import sys
 from argparse import ArgumentParser
-from asyncioffmpeg.runner import runner
 
 
 async def coro_worker(i: int, Niter: int, tic: float):
@@ -97,7 +96,7 @@ def mp_worker(i: int, Niter: int, tic: float):
             ps.append(p)
 
     if A.method == "c":
-        runner(coro, A.Nworker, A.Niter, tic)
+        asyncio.run(coro(A.Nworker, A.Niter, tic))
     elif A.method == "p":
         for p in ps:
             p.join()

examples/play_coroutine.py

@@ -1,8 +1,8 @@
 #!/usr/bin/env python3
 from argparse import ArgumentParser
+import asyncio
 
 import asyncioffmpeg.ffplay as play
-from asyncioffmpeg.runner import runner
 from asyncioffmpeg import get_videos
 
 
@@ -17,4 +17,4 @@
     flist = get_videos(P.path, P.suffix)
     print("found", len(flist), "files in", P.path)
 
-    runner(play.main, flist)
+    asyncio.run(play.main(flist))

examples/probe_coroutine.py

@@ -2,11 +2,12 @@
 """
 ~ 4x speedup over ffprobe_sync
 """
+
 import time
 from argparse import ArgumentParser
+import asyncio
 
 import asyncioffmpeg.ffprobe as probe
-from asyncioffmpeg.runner import runner
 
 
 if __name__ == "__main__":
@@ -19,10 +20,10 @@
 
     tic = time.monotonic()
     # %% emits results as each future is completed
-    runner(probe.get_meta, P.path, P.suffix)
+    asyncio.run(probe.get_meta(P.path, P.suffix))
     print(f"ffprobe asyncio.as_completed: {time.monotonic() - tic:.3f} seconds")
 
     # %% approximately same wallclock time, but only gives results when all futures complete
     tic = time.monotonic()
-    runner(probe.get_meta_gather, P.path, P.suffix)
+    asyncio.run(probe.get_meta_gather(P.path, P.suffix))
     print(f"ffprobe asyncio.gather: {time.monotonic() - tic:.3f} seconds")

setup.cfg

@@ -1,6 +1,6 @@
 [metadata]
 name = asyncioffmpeg
-version = 1.2.0
+version = 1.2.1
 author = Michael Hirsch, Ph.D.
 author_email = scivision@noreply.users.github.com
 url = https://github.com/scivision/asyncio-subprocess-ffmpeg
@@ -15,9 +15,7 @@ classifiers =
   Framework :: AsyncIO
   Intended Audience :: End Users/Desktop
   Operating System :: OS Independent
-  Programming Language :: Python :: 3.7
-  Programming Language :: Python :: 3.8
-  Programming Language :: Python :: 3.9
+  Programming Language :: Python :: 3
   Topic :: Multimedia :: Video :: Conversion
   Topic :: System :: Networking
   Topic :: Utilities
@@ -38,7 +36,7 @@ where=src
 
 [options.extras_require]
 tests =
-  pytest >= 3.9
+  pytest
 lint =
   flake8
   flake8-bugbear

src/asyncioffmpeg/__init__.py

@@ -1,5 +1,10 @@
 from pathlib import Path
 import typing as T
+import os
+import asyncio
+
+if os.name == "nt":
+    asyncio.set_event_loop_policy(asyncio.WindowsProactorEventLoopPolicy())
 
 
 def get_videos(path: Path, suffixes: T.Sequence[str] = None) -> T.List[Path]:

src/asyncioffmpeg/ffprobe.py

@@ -57,7 +57,7 @@ async def ffprobe(file: Path) -> typing.Dict[str, typing.Any]:
             "-show_format",
             str(file),
         ],
-        stdout=asyncio.subprocess.PIPE
+        stdout=asyncio.subprocess.PIPE,
     )
 
     stdout, _ = await proc.communicate()

src/asyncioffmpeg/runner.py

@@ -1,7 +1,7 @@
 from pytest import approx
+import asyncio
 
 import asyncioffmpeg.ffprobe as probe
-from asyncioffmpeg.runner import runner
 
 
 def get_duration(meta: dict) -> float:
@@ -11,15 +11,15 @@ def get_duration(meta: dict) -> float:
 def test_ffprobe_as_completed(genpat):
     vid = genpat
 
-    metas = runner(probe.get_meta, vid.parent, [".avi", ".mp4"])
+    metas = asyncio.run(probe.get_meta(vid.parent, [".avi", ".mp4"]))
     assert len(metas) == 1
     assert get_duration(metas[0]) == approx(5.0)
 
 
 def test_ffprobe_gather(genpat):
     vid = genpat
 
-    metas = runner(probe.get_meta_gather, vid.parent, [".avi", ".mp4"])
+    metas = asyncio.run(probe.get_meta_gather(vid.parent, [".avi", ".mp4"]))
     assert len(metas) == 1
     assert get_duration(metas[0]) == approx(5.0)