After the speech2text is done, save it to the database
Parameters:
| Name |
Type |
Description |
Default |
sender |
|
|
required
|
kwargs |
|
The data passed to the signal
|
{}
|
Source code in API/orchestrator/chain/completed_speech2text.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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68 | @receiver(completed_speech2text)
def trigger_completed_speech2text(sender, **kwargs):
"""
After the speech2text is done, save it to the database
Args:
sender: The sender of the signal
kwargs: The data passed to the signal
"""
logger.info("Speech2Text completed triggerred")
data = kwargs.get("data", {})
track_id = kwargs.get("track_id", None)
task_data = TaskData(**data)
params = task_data.parameters
logger.info(track_id)
uid = params.get("uid")
home_id = params.get("home_id")
audio_index = params.get("audio_index")
audio = DataAudio.objects.filter(
home_id=home_id, uid=uid, sequence_index=audio_index
)
logger.debug(audio)
if not audio:
logger.error("Audio not found")
return
if len(audio) > 1:
logger.error("Multiple audio found")
return
audio_obj = audio.first()
# save the data to the database
result_json = task_data.result_json
result_profile = result_json.get("result_profile", {})
text = result_profile.get("text", "")
logger.debug(result_json)
data_text_obj = DataText.objects.filter(audio=audio_obj).first()
if data_text_obj:
data_text_obj.text = text
data_text_obj.save()
else:
data_text_obj = DataText(
audio=audio_obj,
text=text,
)
data_text_obj.save()
audio_obj.multi_modal_conversation.text = data_text_obj
audio_obj.multi_modal_conversation.save()
ClusterManager.chain_next(
track_id=track_id,
current_component="completed_speech2text",
next_component_params={"sender": data_text_obj, "data": data_text_obj.__dict__},
user=sender.user,
)
|