We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6d104db commit 137da48Copy full SHA for 137da48
1 file changed
src/deepset_mcp/main.py
@@ -71,7 +71,6 @@ async def list_pipelines() -> dict[str, Any]:
71
72
73
@mcp.tool()
74
-@async_to_sync
75
async def get_pipeline(pipeline_id: str) -> dict[str, Any]:
76
"""Fetches detailed configuration information for a specific pipeline, identified by its unique `pipeline_id`.
77
@@ -82,7 +81,7 @@ async def get_pipeline(pipeline_id: str) -> dict[str, Any]:
82
81
"""
83
try:
84
async with DeepsetClient() as client:
85
- return await client.get_pipeline(pipeline_id)
+ return await client.request(f"/workspaces/{client.workspace}/pipelines/{pipeline_id}")
86
except Exception as e:
87
return {"error": str(e)}
88
0 commit comments