black format

Author: scivision

.flake8

@@ -1,3 +1,3 @@
 [flake8]
-max-line-length = 132
+max-line-length = 110
 exclude = .git,__pycache__,.eggs/,doc/,docs/,build/,dist/,archive/

README.md

@@ -1,4 +1,4 @@
-# asyncio FFmpeg
+# Python asyncio FFmpeg
 
 [![Actions Status](https://github.com/scivision/asyncio-subprocess-ffmpeg/workflows/ci/badge.svg)](https://github.com/scivision/asyncio-subprocess-ffmpeg/actions)
 
@@ -50,19 +50,3 @@ Even though coroutines are more efficient in many applications, the syntax of `c
 ### Coroutine
 
 * play_coroutine.py: `asyncio` coroutine event loop to spawn processes.
-
-### Fortran
-
-* `play_coarray.f90`: example of using Fortran with processes and coarrays.
-
-Build by
-
-```sh
-meson build
-meson compile -C build
-```
-
-run like
-```sh
-cafrun -np 3 playvid ~/Videos/*
-```

examples/demo.py

@@ -12,11 +12,14 @@
 
 We didn't break out worker setup time from computation time.
 In real-world situations, coroutines can be faster and less resource-consuming than threads.
-There is no one best choice for all task types, we fit the asynchronous architecture to the task.
-There are numerous other popular implementations of threading and coroutines beyond the built-in modules used here.
-
-In computation-bound programs like this example, coroutines and threads would generally not be as good a choice
-as multiprocessing. However, the heavier resource usage of multiprocessing is not necessarily best for IO-bound tasks
+There is no one best choice for all task types,
+we fit the asynchronous architecture to the task.
+There are numerous other popular implementations of threading and coroutines
+beyond the built-in modules used here.
+
+In computation-bound programs like this example, coroutines and threads would
+generally not be as good a choice as multiprocessing.
+However, the heavier resource usage of multiprocessing is not necessarily best for IO-bound tasks
 such as waiting for network connections, where coroutines and/or threads are often a better choice.
 """
 
@@ -62,7 +65,7 @@ def run(self):
 
 
 def mp_worker(i: int, Niter: int, tic: float):
-    """ multiprocessing worker"""
+    """multiprocessing worker"""
     for _ in range(Niter):
         math.sin(3)
 
@@ -78,7 +81,10 @@ def mp_worker(i: int, Niter: int, tic: float):
     )
     P.add_argument("-Nworker", help="number of workers", type=int, default=4)
     P.add_argument(
-        "-Niter", help="number of loop iterations (arbitrary)", type=int, default=5000000,
+        "-Niter",
+        help="number of loop iterations (arbitrary)",
+        type=int,
+        default=5000000,
     )
     A = P.parse_args()
 

examples/play_coroutine.py

@@ -6,15 +6,16 @@
 from asyncioffmpeg import get_videos
 
 
-if __name__ == "__main__":
-    p = ArgumentParser(description="Plays media files asynchronously with FFplay")
-    p.add_argument("path", help="directory where media files are kept")
-    p.add_argument(
-        "-suffix", help="file suffixes of desired media file types", nargs="+",
-    )
-    P = p.parse_args()
+p = ArgumentParser(description="Plays media files asynchronously with FFplay")
+p.add_argument("path", help="directory where media files are kept")
+p.add_argument(
+    "-suffix",
+    help="file suffixes of desired media file types",
+    nargs="+",
+)
+P = p.parse_args()
 
-    flist = get_videos(P.path, P.suffix)
-    print("found", len(flist), "files in", P.path)
+flist = get_videos(P.path, P.suffix)
+print("found", len(flist), "files in", P.path)
 
-    asyncio.run(play.main(flist))
+asyncio.run(play.main(flist))

examples/play_thread.py

@@ -25,7 +25,9 @@ def ffplay(filein: Path):
     p = ArgumentParser(description="Asynchronous playback with ThreadPool and FFplay")
     p.add_argument("path", help="directory where media files are kept")
     p.add_argument(
-        "-suffix", help="file suffixes of desired media file types", nargs="+",
+        "-suffix",
+        help="file suffixes of desired media file types",
+        nargs="+",
     )
     P = p.parse_args()
 

examples/play_thread_queue.py

@@ -28,7 +28,9 @@ def main(qin: queue.Queue):
     p = ArgumentParser(description="Asynchronous playback with ThreadPool and FFplay")
     p.add_argument("path", help="directory where media files are kept")
     p.add_argument(
-        "-suffix", help="file suffixes of desired media file types", nargs="+",
+        "-suffix",
+        help="file suffixes of desired media file types",
+        nargs="+",
     )
     P = p.parse_args()
 

examples/probe_coroutine.py

@@ -10,20 +10,21 @@
 import asyncioffmpeg.ffprobe as probe
 
 
-if __name__ == "__main__":
-    p = ArgumentParser(description="Get media metadata asynchronously with FFprobe")
-    p.add_argument("path", help="directory where media files are kept")
-    p.add_argument(
-        "-suffix", help="file suffixes of desired media file types", nargs="+",
-    )
-    P = p.parse_args()
+p = ArgumentParser(description="Get media metadata asynchronously with FFprobe")
+p.add_argument("path", help="directory where media files are kept")
+p.add_argument(
+    "-suffix",
+    help="file suffixes of desired media file types",
+    nargs="+",
+)
+P = p.parse_args()
 
-    tic = time.monotonic()
-    # %% emits results as each future is completed
-    asyncio.run(probe.get_meta(P.path, P.suffix))
-    print(f"ffprobe asyncio.as_completed: {time.monotonic() - tic:.3f} seconds")
+tic = time.monotonic()
+# %% emits results as each future is completed
+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()
-    asyncio.run(probe.get_meta_gather(P.path, P.suffix))
-    print(f"ffprobe asyncio.gather: {time.monotonic() - tic:.3f} seconds")
+# %% approximately same wallclock time, but only gives results when all futures complete
+tic = time.monotonic()
+asyncio.run(probe.get_meta_gather(P.path, P.suffix))
+print(f"ffprobe asyncio.gather: {time.monotonic() - tic:.3f} seconds")

examples/probe_sync.py

@@ -6,17 +6,18 @@
 from asyncioffmpeg import get_videos
 
 
-if __name__ == "__main__":
-    p = ArgumentParser(description="Get media metadata synchronously with FFprobe")
-    p.add_argument("path", help="directory where media files are kept")
-    p.add_argument(
-        "-suffix", help="file suffixes of desired media file types", nargs="+",
-    )
-    P = p.parse_args()
+p = ArgumentParser(description="Get media metadata synchronously with FFprobe")
+p.add_argument("path", help="directory where media files are kept")
+p.add_argument(
+    "-suffix",
+    help="file suffixes of desired media file types",
+    nargs="+",
+)
+P = p.parse_args()
 
-    tic = time.monotonic()
-    for f in get_videos(P.path, P.suffix):
-        meta = probe.ffprobe_sync(f)
-        probe.print_meta(meta)
+tic = time.monotonic()
+for f in get_videos(P.path, P.suffix):
+    meta = probe.ffprobe_sync(f)
+    probe.print_meta(meta)
 
-    print(f"ffprobe sync: {time.monotonic() - tic:.3f} seconds")
+print(f"ffprobe sync: {time.monotonic() - tic:.3f} seconds")

src/asyncioffmpeg/ffprobe.py

@@ -24,7 +24,7 @@ def print_meta(meta: typing.Dict[str, typing.Any]):
 
 
 async def get_meta_gather(path: Path, suffix: str) -> typing.List[typing.Dict[str, typing.Any]]:
-    """ for comparison with asyncio.as_completed"""
+    """for comparison with asyncio.as_completed"""
     futures = [ffprobe(f) for f in get_videos(path, suffix)]
     metas = await asyncio.gather(*futures)
     for meta in metas:
@@ -45,7 +45,7 @@ async def get_meta(path: Path, suffix: str) -> typing.List[typing.Dict[str, typi
 
 
 async def ffprobe(file: Path) -> typing.Dict[str, typing.Any]:
-    """ get media metadata """
+    """get media metadata"""
     proc = await asyncio.create_subprocess_exec(
         *[
             FFPROBE,
@@ -66,7 +66,7 @@ async def ffprobe(file: Path) -> typing.Dict[str, typing.Any]:
 
 
 def ffprobe_sync(file: Path) -> typing.Dict[str, typing.Any]:
-    """ get media metadata """
+    """get media metadata"""
     meta = subprocess.check_output(
         [
             FFPROBE,