9.9.24.72 updated recursion for chains.py

update execute_concurrent with recursion for traverse along the prompt
chain.
On branch main
modified: chains.py

chains.py

@@ -1,9 +1,10 @@
 import asyncio
+import openai
 
 from langchain.chat_models import ChatOpenAI
 from langchain.prompts.chat import ChatPromptTemplate
 from langchain.schema import BaseOutputParser
-import openai
+from application import *
 
 from utility import read_pdf,terminal_print
 
@@ -41,11 +42,15 @@ async def execute_concurrent(article,prompts):
     while prompt_list:
         name = prompt_list.pop(0)
         p = prompts[name]
+
+        missing_inputs = [s for s in p["input_list"] if s not in article]
+        for x in missing_inputs:
+            await execute_concurrent(article,{x:app_data["prompts"][x]})
         
-        if any([s not in article for s in p["input_list"]]):
-            # prompt_list.append(name)
-            print("skip",name,"due to missing input",p["input_list"])
-            continue
+        # if any([s not in article for s in p["input_list"]]):
+        #     # prompt_list.append(name)
+        #     print("skip",name,"due to missing input",p["input_list"])
+        #     continue
 
         print("executing",p["assessment_step"],name)
         input_text = "".join([article[s] for s in p["input_list"]])