This will create the response, which will be a text 2 text task
Source code in API/orchestrator/chain/completed_openai_gpt_35.py
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44 | @receiver(completed_openai_gpt_35)
def trigger_completed_openai_gpt_35(sender, **kwargs): # noqa
"""
This will create the response, which will be a text 2 text task
"""
try:
logger.info("OpenAI GPT 35 LLM completed triggerred")
data = kwargs.get("data", {})
track_id = kwargs.get("track_id", None)
logger.info(data)
task_data = TaskData(**data)
if track_id is None:
logger.error("No track_id found")
return
text = task_data.result_json["result_profile"]["text"]
logger.info(text)
data_multimodal_conversation_log_res_text(
task_data=task_data,
text=text,
)
data_text_id = task_data.parameters.get("data_text_id", None)
ClusterManager.chain_next(
track_id=track_id,
current_component="completed_openai_gpt_35",
next_component_params={"text": text, "data_text_id": data_text_id},
user=sender.user,
)
except Exception as e:
logger.exception(e)
return
|