Aleix Conchillo Flaqué
0f5030bafa
tests: add unit test to check for idle timeout on swallowed frames
2025-10-31 08:45:56 -07:00
Aleix Conchillo Flaqué
1b9e96c016
PipelineTask: fix task cancellation issues
2025-10-16 13:16:19 -07:00
Aleix Conchillo Flaqué
62b7c3d3b2
PipelineTask: add on_pipeline_error event
2025-10-07 18:36:38 -07:00
Aleix Conchillo Flaqué
db71089f5e
PipelineTask: add on_pipeline_finished event
...
This deprecates `on_pipeline_stopped`, `on_pipeline_ended` and
`on_pipeline_cancelled`.
2025-09-15 15:28:33 -07:00
Aleix Conchillo Flaqué
74b38b59d6
tests(utils): allow passing PipelineParams to run_test()
2025-09-11 13:02:21 -07:00
Aleix Conchillo Flaqué
8ab81d289a
PipelineTask: warn if CancelFrame doesn't reach the end
2025-08-26 10:36:33 -07:00
Aleix Conchillo Flaqué
8044c4170d
PipelineRunner/PipelineTask: fix asyncio task cancellation
2025-08-21 23:50:00 -07:00
Aleix Conchillo Flaqué
28c729cc36
replace asyncio.wait_for for wait_for2.wait_for
2025-08-20 15:26:57 -07:00
Aleix Conchillo Flaqué
f387776985
add custom asyncio.wait_for()
...
This patch uses `wait_for2` package to implement `asyncio.wait_for()` for
Python < 3.12.
In Python 3.12, `asyncio.wait_for()` is implemented in terms of
`asyncio.timeout()` which fixed a bunch of issues. However, this was never
backported (because of the lack of `async.timeout()`) and there are still many
remainig issues, specially in Python 3.10, in `async.wait_for()`.
See https://github.com/python/cpython/pull/98518
2025-08-20 14:09:05 -07:00
Aleix Conchillo Flaqué
5a3457ba33
introduce task watchdog timers
2025-06-24 11:56:20 -07:00
Aleix Conchillo Flaqué
028f7b2d65
PipelineTask: fix repeated on_idle_timeout
2025-06-19 09:14:10 -07:00
Paul Kompfner
513ce26200
Add unit test exercising synchronous usage of PipelineTask.add_observer() right after initializing the PipelineTask (before anything else is done with it)
2025-06-09 11:30:24 -04:00
Paul Kompfner
1cd96f94ff
Make PipelineTask.add_observer() synchronous. This allows callers to call it before run()ning the PipelineTask first. Without this change, if they tried to do that, they would get an error because the TaskManager's event loop hadn't been set yet.
2025-06-09 11:30:24 -04:00
Aleix Conchillo Flaqué
d333094149
PipelineTask: add add_observer() and remove_observer()
2025-05-20 13:16:06 -07:00
Aleix Conchillo Flaqué
d5ebc883b3
PipelineTask: add new started/stopped/ended/cancelled events
2025-05-17 22:46:22 -07:00
Aleix Conchillo Flaqué
e18d9f6a11
PipelineTask: automatically cancel tasks if pipeline is idle
2025-03-19 23:30:46 -07:00
Aleix Conchillo Flaqué
1b3b4ee04a
PipelineTask: only call event handlers if a filter is matched
2025-03-13 18:44:30 -07:00
Aleix Conchillo Flaqué
25dcf7def6
PipelineTask: add on_frame_reached_upstream/on_frame_reached_downstream
2025-03-13 10:26:11 -07:00
Aleix Conchillo Flaqué
6028f0f23a
PipelineTask: pass observers in contructor parameter
2025-02-24 21:29:17 -08:00
Aleix Conchillo Flaqué
d1ee851a65
tests: rename some variables to make things clearer
2025-02-13 13:20:37 -08:00
Aleix Conchillo Flaqué
feab9c8fa2
tests: run_test() now uses PipelineTask
2025-02-05 10:34:38 -08:00
Aleix Conchillo Flaqué
d95819746a
tests: make sure QueuedFrameProcessor push frames
2025-01-30 13:48:44 -08:00
Vaibhav159
8407a86532
moving test utils inside of package
2025-01-29 12:46:43 +05:30
Aleix Conchillo Flaqué
401d3ff267
tests: added PipelineTask tests
2025-01-21 11:45:43 -08:00
Aleix Conchillo Flaqué
177cb2ca8b
tests: initial pipeline and parallelpipeline tests
2025-01-21 09:57:54 -08:00
Aleix Conchillo Flaqué
090bc81ec5
tests: add some initial run_test() utilities
2025-01-20 17:41:21 -08:00
Aleix Conchillo Flaqué
17162258a2
fix ruff linter import organization
2024-12-17 11:28:58 -08:00
Aleix Conchillo Flaqué
eeb8338dce
introduce Ruff formatting
2024-09-23 09:53:37 -07:00
mattie ruth backman
50b45ac2da
get the test infrastructure running again
...
disable broken tests for now
2024-09-19 20:58:17 -04:00
Aleix Conchillo Flaqué
b026915d19
initial commit for new pipecat architecture
2024-05-12 10:07:25 -07:00
Moishe Lettvin
5c0ba1b6f0
Fix off by one errors, add tests and comment
2024-03-28 08:34:34 -04:00
Aleix Conchillo Flaqué
16257f8ec0
move src/dailyai/tests to tests
2024-03-19 14:59:48 -07:00
