-
Notifications
You must be signed in to change notification settings - Fork 2.3k
AGT-2182: Add inference bargein and examples #4032
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
AGT-2182: Add inference bargein and examples #4032
Conversation
1fe7b1b to
783b91a
Compare
783b91a to
3d9d0af
Compare
theomonnom
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nice work!
7b11b1d to
13a6fed
Compare
6dfc839 to
45b5664
Compare
120b12c to
bab9b18
Compare
5868880 to
dbf4dbc
Compare
| self._log(DEV_LEVEL, message, args, **kwargs) | ||
|
|
||
|
|
||
| logging.setLoggerClass(Logger) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
TIL we can do that
| BargeinError, | ||
| BargeinEvent, | ||
| BargeinEventType, | ||
| BargeinStreamBase, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| BargeinStreamBase, |
Should this one stays internal?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
good point!
| self.update_vad(None) | ||
| self.update_bargein_detector(None) | ||
|
|
||
| def start_barge_in_monitoring(self) -> None: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think it's totally fine to name this:
on_agent_started_speaking
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|
|
||
| self._bargein_ch.send_nowait(inference.BargeinStreamBase._OverlapSpeechEndedSentinel()) | ||
|
|
||
| def end_barge_in_monitoring(self, ignore_until: float) -> None: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
on_agent_stopped_speaking
|
|
||
| self._bargein_ch.send_nowait(inference.BargeinStreamBase._OverlapSpeechEndedSentinel()) | ||
|
|
||
| def end_barge_in_monitoring(self, ignore_until: float) -> None: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's make it a kwargs & rename the parameter, otherwise it isn't obvious when reading the code from other places
| def end_barge_in_monitoring(self, ignore_until: float) -> None: | |
| def end_barge_in_monitoring(self, *, ignore_transcript_until: float) -> None: |
2a2c610 to
817caa5
Compare


Detailed spec can be found in the notion page