Spaces:
Runtime error
Runtime error
Commit ·
dbcd902
1
Parent(s): 2a4b462
added queryHelperCot
Browse files
app.py
CHANGED
|
@@ -15,6 +15,7 @@ from constants import *
|
|
| 15 |
from utils import *
|
| 16 |
from gptManager import ChatgptManager
|
| 17 |
from queryHelperManager import QueryHelper
|
|
|
|
| 18 |
|
| 19 |
|
| 20 |
pd.set_option('display.max_columns', None)
|
|
@@ -45,8 +46,8 @@ queryHelper = QueryHelper(gptInstance=gptInstance,
|
|
| 45 |
|
| 46 |
|
| 47 |
openAIClient2 = OpenAI(api_key=OPENAI_API_KEY)
|
| 48 |
-
|
| 49 |
-
|
| 50 |
schemaName=SCHEMA_NAME,platform=PLATFORM,
|
| 51 |
metadataLayout=metadataLayout,
|
| 52 |
sampleDataRows=SAMPLE_ROW_MAX,
|
|
@@ -83,20 +84,20 @@ def respond(message, chatHistory):
|
|
| 83 |
return "", chatHistory
|
| 84 |
|
| 85 |
# Function to save history of chat
|
| 86 |
-
def
|
| 87 |
"""gpt response handler for gradio ui"""
|
| 88 |
global queryHelper
|
| 89 |
try:
|
| 90 |
if "modify" in message:
|
| 91 |
-
botMessage, prospectTablesAndCols =
|
| 92 |
else:
|
| 93 |
-
botMessage, prospectTablesAndCols =
|
| 94 |
except Exception as e:
|
| 95 |
errorMessage = {"function":"queryHelperFineTuned.getQueryForUserInput","error":str(e), "userInput":message}
|
| 96 |
saveLog(errorMessage, 'error')
|
| 97 |
raise ValueError(str(e))
|
| 98 |
queryGenerated = extractSqlFromGptResponse(botMessage)
|
| 99 |
-
logMessage = {"userInput":message, "tablesColsSelectedByGpt":str(prospectTablesAndCols) , "queryGenerated":queryGenerated, "completeGptResponse":botMessage, "function":"
|
| 100 |
saveLog(logMessage)
|
| 101 |
chatHistory.append((message, botMessage))
|
| 102 |
time.sleep(2)
|
|
@@ -225,12 +226,12 @@ with gr.Blocks() as demo:
|
|
| 225 |
clear = gr.ClearButton([msg, chatbot])
|
| 226 |
msg.submit(respond, [msg, chatbot], [msg, chatbot])
|
| 227 |
|
| 228 |
-
with gr.Tab("Query Helper
|
| 229 |
gr.Markdown("""<h1><center> Query Helper Fine Tuned</center></h1>""")
|
| 230 |
chatbot = gr.Chatbot()
|
| 231 |
msg = gr.Textbox()
|
| 232 |
clear = gr.ClearButton([msg, chatbot])
|
| 233 |
-
msg.submit(
|
| 234 |
|
| 235 |
# screen 2 : To run sql query against database
|
| 236 |
with gr.Tab("Run Query"):
|
|
|
|
| 15 |
from utils import *
|
| 16 |
from gptManager import ChatgptManager
|
| 17 |
from queryHelperManager import QueryHelper
|
| 18 |
+
from queryHelperManagerCoT import QueryHelperChainOfThought
|
| 19 |
|
| 20 |
|
| 21 |
pd.set_option('display.max_columns', None)
|
|
|
|
| 46 |
|
| 47 |
|
| 48 |
openAIClient2 = OpenAI(api_key=OPENAI_API_KEY)
|
| 49 |
+
gptInstance2 = ChatgptManager(openAIClient2, model=GPT_MODEL)
|
| 50 |
+
queryHelperCot = QueryHelperChainOfThought(gptInstance=gptInstance2,
|
| 51 |
schemaName=SCHEMA_NAME,platform=PLATFORM,
|
| 52 |
metadataLayout=metadataLayout,
|
| 53 |
sampleDataRows=SAMPLE_ROW_MAX,
|
|
|
|
| 84 |
return "", chatHistory
|
| 85 |
|
| 86 |
# Function to save history of chat
|
| 87 |
+
def respondCoT(message, chatHistory):
|
| 88 |
"""gpt response handler for gradio ui"""
|
| 89 |
global queryHelper
|
| 90 |
try:
|
| 91 |
if "modify" in message:
|
| 92 |
+
botMessage, prospectTablesAndCols = queryHelperCot.getQueryForUserInputCoT(message, chatHistory)
|
| 93 |
else:
|
| 94 |
+
botMessage, prospectTablesAndCols = queryHelperCot.getQueryForUserInput(message, [])
|
| 95 |
except Exception as e:
|
| 96 |
errorMessage = {"function":"queryHelperFineTuned.getQueryForUserInput","error":str(e), "userInput":message}
|
| 97 |
saveLog(errorMessage, 'error')
|
| 98 |
raise ValueError(str(e))
|
| 99 |
queryGenerated = extractSqlFromGptResponse(botMessage)
|
| 100 |
+
logMessage = {"userInput":message, "tablesColsSelectedByGpt":str(prospectTablesAndCols) , "queryGenerated":queryGenerated, "completeGptResponse":botMessage, "function":"queryHelperCot.getQueryForUserInputCoT"}
|
| 101 |
saveLog(logMessage)
|
| 102 |
chatHistory.append((message, botMessage))
|
| 103 |
time.sleep(2)
|
|
|
|
| 226 |
clear = gr.ClearButton([msg, chatbot])
|
| 227 |
msg.submit(respond, [msg, chatbot], [msg, chatbot])
|
| 228 |
|
| 229 |
+
with gr.Tab("Query Helper CoT"):
|
| 230 |
gr.Markdown("""<h1><center> Query Helper Fine Tuned</center></h1>""")
|
| 231 |
chatbot = gr.Chatbot()
|
| 232 |
msg = gr.Textbox()
|
| 233 |
clear = gr.ClearButton([msg, chatbot])
|
| 234 |
+
msg.submit(respondCoT, [msg, chatbot], [msg, chatbot])
|
| 235 |
|
| 236 |
# screen 2 : To run sql query against database
|
| 237 |
with gr.Tab("Run Query"):
|