Log execution time in each future result.

Author: toddbirchard

asyncio_tutorial/__init__.py

@@ -1,5 +1,6 @@
 """Demonstrate Parts 1 and 2 of Hackersandslackers Asyncio tutorial series"""
 import asyncio
+import time
 
 from asyncio_tutorial.logger import LOGGER
 
@@ -14,5 +15,6 @@ def init_script():
     1. Intro to Async Python: https://hackersandslackers.com/python-concurrency-asyncio/
     2. Intro to Async Python: https://hackersandslackers.com/async-requests-with-aiohttp/
     """
-    asyncio.run(asyncio_intro_tutorial())
-    asyncio.run(aiohttp_aiofiles_tutorial())
+    start_time = time.perf_counter()
+    asyncio.run(asyncio_intro_tutorial(start_time))
+    asyncio.run(aiohttp_aiofiles_tutorial(start_time))

asyncio_tutorial/part_II_aiohttp_aiofiles/__init__.py

@@ -1,5 +1,6 @@
-"""Script initialization."""
+"""Make hundreds of requests concurrently and save responses to disk."""
 import asyncio
+import time
 
 from aiohttp import ClientSession
 
@@ -12,12 +13,18 @@
 from .tasks import create_tasks
 
 
-async def aiohttp_aiofiles_tutorial():
-    """Open async HTTP session & execute created tasks."""
+async def aiohttp_aiofiles_tutorial(start_time):
+    """
+    Open async HTTP session & execute created tasks.
+
+    :param float start_time: Counter representing the time the script was initialized.
+    """
     LOGGER.info(f"Asyncio tutorial Part II: HTTP Requests with Aiohttp & Aiofiles.")
     future = register_future()
     async with ClientSession(headers=HTML_HEADERS) as session:
         tasks = await create_tasks(session, urls, EXPORT_DIR)
         inspect_event_loop()
         await asyncio.gather(*tasks)
-    future.set_result(f"Saved {len(urls)} files to `{EXPORT_DIR}`")
+    future.set_result(
+        f"Executed {__name__} in {time.perf_counter() - start_time:0.2f} seconds."
+    )

asyncio_tutorial/part_I_asyncio_intro/__init__.py

@@ -1,5 +1,6 @@
 """Create and execute asynchronous tasks in a loop."""
 import asyncio
+import time
 
 from asyncio_tutorial.logger import LOGGER
 
@@ -9,8 +10,12 @@
 from .tasks import create_task
 
 
-async def asyncio_intro_tutorial():
-    """Demo of an asynchronous script's lifecycle."""
+async def asyncio_intro_tutorial(start_time: float):
+    """
+    Demo of an asynchronous script's lifecycle.
+
+    :param float start_time: Counter representing the time the script was initialized.
+    """
     LOGGER.info(f"Asyncio tutorial Part I: Intro to Asyncio.")
     task_list = []
     future = register_future()
@@ -19,4 +24,6 @@ async def asyncio_intro_tutorial():
         task_list.append(task)
     inspect_event_loop()
     await asyncio.gather(*task_list)
-    future.set_result("Done")
+    future.set_result(
+        f"Executed {__name__} in {time.perf_counter() - start_time:0.2f} seconds."
+    )

asyncio_tutorial/part_I_asyncio_intro/futures.py

@@ -21,9 +21,9 @@ def loop_completed(result: str):
     """
     Callback function fired when loop is complete.
 
-    :param str result: String describing the state of the loop
+    :param str result: Message describing the state of the loop & its execution time.
     """
     LOGGER.success(
-        f"Loop completed with result: {result} \
+        f"{result} \
         \n--------------------------------------"
     )

asyncio_tutorial/part_I_asyncio_intro/tasks.py

@@ -1,7 +1,7 @@
 """Create task from coroutine which displays a value after a delay."""
-from typing import Callable
 import asyncio
 from asyncio import Task
+from typing import Callable
 
 
 async def create_task(coroutine: Callable) -> Task:

config.py

@@ -16,4 +16,3 @@
     "connection": "keep-alive",
     "accept": "*/*",
 }
-

poetry.lock

@@ -16,4 +16,4 @@ pycares==4.0.0
 pycparser==2.20; python_version >= "2.7" and python_full_version < "3.0.0" or python_full_version >= "3.4.0"
 typing-extensions==3.10.0.2; python_version >= "3.6"
 win32-setctime==1.0.3; sys_platform == "win32" and python_version >= "3.5"
-yarl==1.6.3; python_version >= "3.6"
+yarl==1.7.0; python_version >= "3.6"