|
Ran
|
Jobs
1
|
Files
54
|
Run time
1min
|
Badge
README BADGES
|
push
github
feat: AsyncPipeline that can schedule components to run concurrently (#180) * chore: move shared methods to base class * feat: implement async pipeline that runs concurrently * test: update and fix tests * chore: update example notebook * chore: add missing header * remove unused import * try test run without Opensearch * Revert "try test run without Opensearch" This reverts commit 4fbd59b11. * debug: test without openai * chore: add more test cases * feat: add sync run method * Update haystack_experimental/core/pipeline/async_pipeline.py Co-authored-by: Amna Mubashar <amnahkhan.ak@gmail.com> * Update haystack_experimental/core/pipeline/async_pipeline.py Co-authored-by: Amna Mubashar <amnahkhan.ak@gmail.com> * Update haystack_experimental/core/pipeline/async_pipeline.py Co-authored-by: Amna Mubashar <amnahkhan.ak@gmail.com> * Update haystack_experimental/core/pipeline/async_pipeline.py Co-authored-by: Amna Mubashar <amnahkhan.ak@gmail.com> * fix: indentation * better naming * chore: complete tracing * test: test for pipeline reentrance * fix: component visits should not be part of pipeline state * chore: docstring * fix: priority calculation * test: unit test sync pipeline * test: test sync and async implementation * fix: format --------- Co-authored-by: Amna Mubashar <amnahkhan.ak@gmail.com>
1444 of 2078 relevant lines covered (69.49%)
0.69 hits per line
| Lines | Coverage | ∆ | File |
|---|---|---|---|
| 1 |
75.0 |
-25.0% | util/asynchronous.py |
| 2 |
0.0 |
-100.0% | dataclasses/__init__.py |
| 9 |
80.3 |
56.52% | core/pipeline/pipeline.py |
| 17 |
0.0 |
-100.0% | dataclasses/streaming_chunk.py |
| 68 |
57.5 |
-9.17% | core/pipeline/async_pipeline.py |
| 163 |
46.96 |
30.08% | core/pipeline/base.py |
| ID | Job ID | Ran | Files | Coverage | |
|---|---|---|---|---|---|
| 1 | 13132040977.1 | 54 |
69.49 |
GitHub Action Run |
| Coverage | ∆ | File | Lines | Relevant | Covered | Missed | Hits/Line |
|---|