9.9.24.74 updated the async function terminal

After the updated of async functions, the original terminal_print
function is not working for async functions.

This commit is to add an aterminal_print as the async version of
terminal_print to wrap around async functions.

chains.py

@@ -6,7 +6,7 @@ from langchain.prompts.chat import ChatPromptTemplate
 from langchain.schema import BaseOutputParser
 from application import *
 
-from utility import read_pdf,terminal_print
+from utility import read_pdf,aterminal_print
 
 class Replacement(BaseOutputParser):
     """Parse the output of an LLM call to a comma-separated list."""
@@ -18,7 +18,7 @@ class Replacement(BaseOutputParser):
             print(kwargs)
         return text.strip().split(", ")
 
-@terminal_print # need to review this.
+@aterminal_print # need to review this.
 async def async_generate(article,name,chain,replacement_term=None):
     if replacement_term:
         resp = await chain.ainvoke({"term":replacement_term})
@@ -26,7 +26,7 @@ async def async_generate(article,name,chain,replacement_term=None):
         resp = await chain.ainvoke({"term":""})
     article[name] = resp.content
 
-@terminal_print # need to review this.
+@aterminal_print # need to review this.
 async def execute_concurrent(article,prompts):
     llm = ChatOpenAI(
         temperature=0.0,

features.py

@@ -144,13 +144,13 @@ def update_article_segment(article):
         tasks.append(get_segments(article,article_prompts))
         asyncio.gather(*tasks,return_exceptions=True)
     
-@terminal_print # need to review this.
+@aterminal_print # need to review this.
 async def gen_segment(article,name,chain):
     
     resp = await chain.ainvoke({"term":""})
     article[name] = resp.content #["content"]
 
-@terminal_print # need to review this.
+@aterminal_print # need to review this.
 async def get_segments(article,prompts):
     llm = ChatOpenAI(
         temperature=0.0,

utility.py

@@ -1,6 +1,7 @@
 import json
 import regex as re
 import tiktoken
+import asyncio
 
 from application import *
 from pdfminer.high_level import extract_text
@@ -13,6 +14,21 @@ encoding = tiktoken.get_encoding("cl100k_base")
 universal system functions
 '''
 
+def aterminal_print(afunc):
+    from datetime import datetime
+    async def wrapper(*args, **kwargs):
+        start = datetime.now()
+        print(f"{start.strftime('%y-%m-%d %H:%M:%S')} - executing function: {afunc.__name__}")
+
+        result = await afunc(*args, **kwargs)
+        
+        end = datetime.now()
+        print(f"{end.strftime('%y-%m-%d %H:%M:%S')} - completed function: {afunc.__name__}, runtime: {end-start} seconds")
+
+        return result
+
+    return wrapper
+
 def terminal_print(func):
     from datetime import datetime
     # import os