From 0383efa20750eb80785e299f84eeedc5e81d3f8a Mon Sep 17 00:00:00 2001 From: "Timothy J. Baek" Date: Tue, 28 May 2024 11:43:48 -0700 Subject: [PATCH] refac: pipelines --- backend/main.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/backend/main.py b/backend/main.py index b5a1569b8..0e5924574 100644 --- a/backend/main.py +++ b/backend/main.py @@ -245,6 +245,7 @@ class PipelineMiddleware(BaseHTTPMiddleware): model for model in app.state.MODELS.values() if "pipeline" in model + and "type" in model["pipeline"] and model["pipeline"]["type"] == "filter" and ( model["pipeline"]["pipelines"] == ["*"] @@ -279,11 +280,10 @@ class PipelineMiddleware(BaseHTTPMiddleware): if key != "": headers = {"Authorization": f"Bearer {key}"} r = requests.post( - f"{url}/filter", + f"{url}/{filter['id']}/filter", headers=headers, json={ "user": user, - "model": filter["id"], "body": data, }, ) @@ -448,7 +448,7 @@ async def get_models(user=Depends(get_verified_user)): models = [ model for model in models - if "pipeline" not in model or model["pipeline"]["type"] != "filter" + if "pipeline" not in model or model["pipeline"].get("type", None) != "filter" ] if app.state.config.ENABLE_MODEL_FILTER: