open-webui/pipelines
1
0
Fork 0
mirror of https://github.com/open-webui/pipelines.git synced 2026-07-21 01:55:22 -04:00
Code Issues 188 Packages Projects Releases Wiki Activity

filter pipeline with valves without pipelines value breaks the pipelines #245

New Issue
Open
opened 2026-02-15 19:17:19 -05:00 by yindo · 0 comments
yindo commented 2026-02-15 19:17:19 -05:00
Owner
Copy Link
Copy Source

Originally created by @sancelot on GitHub (Jul 18, 2025).

I created an hybrid search pipeline. (The reason is that the server that runs open-webui has not gpu resources so, I have to offload it to machines supporting it,that may be not the right way to do it ?)

I create it as follow with valves but without pipelines parameters.

the application fails with the next logs.

I have not pushed a PR, but to correct it, you have to add parenthesis around in main.py :
"pipelines": (
pipeline.valves.pipelines
if (hasattr(pipeline, "valves")
and hasattr(pipeline.valves, "pipelines"))
else []
),

but that sounds a bit more complicated, because it then crashes int get_models()

At the moment, there are few things i have not understood with this pipelines variable intended usage .

exemple pipeline Valves crashing it :

class Pipeline:
    class Valves(BaseModel):
        # Pipeline configuration
        PIPELINE_NAME: str = "Hybrid Search Pipeline"
        HYBRID_SEARCH_API_URL: str = "https://your-hybrid-search-service.com/api/v1"
        HYBRID_SEARCH_API_KEY: str = ""
        BM25_WEIGHT: float = 0.5
        VECTOR_WEIGHT: float = 0.5
        RERANK_ENABLED: bool = True
        RERANK_TOP_K: int = 10
        MIN_RELEVANCE_SCORE: float = 0.0
        REQUEST_TIMEOUT: int = 30

    def __init__(self):
        self.type = "filter"
        self.name = "Hybrid Search"
        self.valves = self.Valves()
        .......

: 10.1.42.88:36712 - "GET /models HTTP/1.1" 500 Internal Server Error
ERROR: Exception in ASGI application

  • Exception Group Traceback (most recent call last):
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette_utils.py", line 87, in collapse_excgroups
    | yield
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\base.py", line 190, in call
    | async with anyio.create_task_group() as task_group:
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\anyio_backends_asyncio.py", line 772, in aexit
    | raise BaseExceptionGroup(
    | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
    +-+---------------- 1 ----------------
    | Traceback (most recent call last):
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\uvicorn\protocols\http\httptools_impl.py", line 435, in run_asgi
    | result = await app( # type: ignore[func-returns-value]
    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\uvicorn\middleware\proxy_headers.py", line 78, in call
    | return await self.app(scope, receive, send)
    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\fastapi\applications.py", line 1054, in call
    | await super().call(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\applications.py", line 123, in call
    | await self.middleware_stack(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\errors.py", line 186, in call
    | raise exc
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\errors.py", line 164, in call
    | await self.app(scope, receive, _send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\base.py", line 189, in call
    | with collapse_excgroups():
    | File "C:\Users\sancelot\AppData\Roaming\uv\python\cpython-3.11.11-windows-x86_64-none\Lib\contextlib.py", line 158, in exit
    | self.gen.throw(typ, value, traceback)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette_utils.py", line 93, in collapse_excgroups
    | raise exc
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\base.py", line 191, in call
    | response = await self.dispatch_func(request, call_next)
    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    | File "E:\WORKSPACE\pipelines\main.py", line 287, in check_url
    | response = await call_next(request)
    | ^^^^^^^^^^^^^^^^^^^^^^^^
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\base.py", line 165, in call_next
    | raise app_exc
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\base.py", line 151, in coro
    | await self.app(scope, receive_or_disconnect, send_no_error)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\cors.py", line 85, in call
    | await self.app(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\middleware\exceptions.py", line 65, in call
    | await wrap_app_handling_exceptions(self.app, conn)(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette_exception_handler.py", line 64, in wrapped_app
    | raise exc
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette_exception_handler.py", line 53, in wrapped_app
    | await app(scope, receive, sender)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\routing.py", line 756, in call
    | await self.middleware_stack(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\routing.py", line 776, in app
    | await route.handle(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\routing.py", line 297, in handle
    | await self.app(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\routing.py", line 77, in app
    | await wrap_app_handling_exceptions(app, request)(scope, receive, send)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette_exception_handler.py", line 64, in wrapped_app
    | raise exc
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette_exception_handler.py", line 53, in wrapped_app
    | await app(scope, receive, sender)
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\starlette\routing.py", line 72, in app
    | response = await func(request)
    | ^^^^^^^^^^^^^^^^^^^
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\fastapi\routing.py", line 278, in app
    | raw_response = await run_endpoint_function(
    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\fastapi\routing.py", line 191, in run_endpoint_function
    | return await dependant.call(**values)
    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    | File "E:\WORKSPACE\pipelines\main.py", line 302, in get_models
    | "data": [
    | ^
    | File "E:\WORKSPACE\pipelines\main.py", line 314, in
    | pipeline["valves"].pipelines
    | File "E:\WORKSPACE\pipelines.venv\Lib\site-packages\pydantic\main.py", line 811, in getattr
    | raise AttributeError(f'{type(self).name!r} object has no attribute {item!r}')
    | AttributeError: 'Valves' object has no attribute 'pipelines'
Originally created by @sancelot on GitHub (Jul 18, 2025). I created an hybrid search pipeline. (The reason is that the server that runs open-webui has not gpu resources so, I have to offload it to machines supporting it,that may be not the right way to do it ?) I create it as follow with valves but without **pipelines** parameters. the application fails with the next logs. I have not pushed a PR, but to correct it, you have to add parenthesis around in [main.py](https://github.com/open-webui/pipelines/blob/main/main.py#L88) : "pipelines": ( pipeline.valves.pipelines if **(**hasattr(pipeline, "valves") and hasattr(pipeline.valves, "pipelines")**)** else [] ), but that sounds a bit more complicated, because it then crashes int get_models() At the moment, there are few things i have not understood with this pipelines variable intended usage . exemple pipeline Valves crashing it : ``` class Pipeline: class Valves(BaseModel): # Pipeline configuration PIPELINE_NAME: str = "Hybrid Search Pipeline" HYBRID_SEARCH_API_URL: str = "https://your-hybrid-search-service.com/api/v1" HYBRID_SEARCH_API_KEY: str = "" BM25_WEIGHT: float = 0.5 VECTOR_WEIGHT: float = 0.5 RERANK_ENABLED: bool = True RERANK_TOP_K: int = 10 MIN_RELEVANCE_SCORE: float = 0.0 REQUEST_TIMEOUT: int = 30 def __init__(self): self.type = "filter" self.name = "Hybrid Search" self.valves = self.Valves() ....... ``` : 10.1.42.88:36712 - "GET /models HTTP/1.1" 500 Internal Server Error ERROR: Exception in ASGI application + Exception Group Traceback (most recent call last): | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\_utils.py", line 87, in collapse_excgroups | yield | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\base.py", line 190, in __call__ | async with anyio.create_task_group() as task_group: | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 772, in __aexit__ | raise BaseExceptionGroup( | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception) +-+---------------- 1 ---------------- | Traceback (most recent call last): | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\uvicorn\protocols\http\httptools_impl.py", line 435, in run_asgi | result = await app( # type: ignore[func-returns-value] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\uvicorn\middleware\proxy_headers.py", line 78, in __call__ | return await self.app(scope, receive, send) | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\fastapi\applications.py", line 1054, in __call__ | await super().__call__(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\applications.py", line 123, in __call__ | await self.middleware_stack(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\errors.py", line 186, in __call__ | raise exc | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\errors.py", line 164, in __call__ | await self.app(scope, receive, _send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\base.py", line 189, in __call__ | with collapse_excgroups(): | File "C:\Users\sancelot\AppData\Roaming\uv\python\cpython-3.11.11-windows-x86_64-none\Lib\contextlib.py", line 158, in __exit__ | self.gen.throw(typ, value, traceback) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\_utils.py", line 93, in collapse_excgroups | raise exc | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\base.py", line 191, in __call__ | response = await self.dispatch_func(request, call_next) | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | File "E:\WORKSPACE\pipelines\main.py", line 287, in check_url | response = await call_next(request) | ^^^^^^^^^^^^^^^^^^^^^^^^ | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\base.py", line 165, in call_next | raise app_exc | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\base.py", line 151, in coro | await self.app(scope, receive_or_disconnect, send_no_error) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\cors.py", line 85, in __call__ | await self.app(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\middleware\exceptions.py", line 65, in __call__ | await wrap_app_handling_exceptions(self.app, conn)(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\_exception_handler.py", line 64, in wrapped_app | raise exc | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\_exception_handler.py", line 53, in wrapped_app | await app(scope, receive, sender) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\routing.py", line 756, in __call__ | await self.middleware_stack(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\routing.py", line 776, in app | await route.handle(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\routing.py", line 297, in handle | await self.app(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\routing.py", line 77, in app | await wrap_app_handling_exceptions(app, request)(scope, receive, send) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\_exception_handler.py", line 64, in wrapped_app | raise exc | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\_exception_handler.py", line 53, in wrapped_app | await app(scope, receive, sender) | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\starlette\routing.py", line 72, in app | response = await func(request) | ^^^^^^^^^^^^^^^^^^^ | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\fastapi\routing.py", line 278, in app | raw_response = await run_endpoint_function( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\fastapi\routing.py", line 191, in run_endpoint_function | return await dependant.call(**values) | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | File "E:\WORKSPACE\pipelines\main.py", line 302, in get_models | "data": [ | ^ | File "E:\WORKSPACE\pipelines\main.py", line 314, in <listcomp> | pipeline["valves"].pipelines | File "E:\WORKSPACE\pipelines\.venv\Lib\site-packages\pydantic\main.py", line 811, in __getattr__ | raise AttributeError(f'{type(self).__name__!r} object has no attribute {item!r}') | AttributeError: 'Valves' object has no attribute 'pipelines'
Sign in to join this conversation.
No Branch/Tag Specified
Branches Tags
Labels
Clear labels
bug
bug
enhancement
enhancement
good first issue
help wanted
pull-request
Mirrored from GitHub Pull Request
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
yindo
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: open-webui/pipelines#245
Delete Branch "%!s()"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?