Commit cce57c4
David Orel
test: 🧪 add comprehensive tests for pipeline scheduler and steps
- Introduced tests for `PipelineScheduler` to validate creation, configuration, and job scheduling methods.
- Added tests for various step classes including `ReduceStep`, `FilterStep`, `MapperStep`, and `SequentialStep` to ensure correct initialization and behavior.
- Implemented tests for tracking manager and storage to verify functionality with in-memory and Redis brokers.
- Created utility tests for `PipelineContext` to check result retrieval and error handling.
- Ensured all tests are structured with appropriate fixtures and async handling for robust testing.1 parent 32d7e74 commit cce57c4
102 files changed
Lines changed: 8030 additions & 840 deletions
File tree
- .github/workflows
- examples
- taskiq_flow
- broker
- dataflow
- hooks
- integration
- websocket
- map_reduce
- scheduling
- stores
- steps
- tracking
- utils
- visualization
- taskiq_pipelines
- broker
- hooks
- integration/websocket
- steps
- tracking
- tests
- test_broker
- test_e2e
- test_hooks
- test_integration
- test_scheduling
- test_steps
- test_tracking
- test_utils
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
160 | 160 | | |
161 | 161 | | |
162 | 162 | | |
163 | | - | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
| 166 | + | |
0 commit comments