Merge pull request #913 from pimutils/async-collections

Sync pairs asynchronously

Author: Hugo Osvaldo Barrera

vdirsyncer/cli/__init__.py

@@ -129,20 +129,24 @@ def sync(ctx, collections, force_delete):
     async def main(collections):
         conn = aiohttp.TCPConnector(limit_per_host=16)
 
+        tasks = []
         for pair_name, collections in collections:
             async for collection, config in prepare_pair(
                 pair_name=pair_name,
                 collections=collections,
                 config=ctx.config,
                 connector=conn,
             ):
-                await sync_collection(
-                    collection=collection,
-                    general=config,
-                    force_delete=force_delete,
-                    connector=conn,
+                tasks.append(
+                    sync_collection(
+                        collection=collection,
+                        general=config,
+                        force_delete=force_delete,
+                        connector=conn,
+                    )
                 )
 
+        await asyncio.gather(*tasks)
         await conn.close()
 
     asyncio.run(main(collections))