OpenWebUI/openapi-servers
1
0
Fork 0
mirror of https://github.com/open-webui/openapi-servers synced 2025-06-26 18:17:04 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix pydantic json schema warnings

Browse Source
This commit is contained in:
Taylor Wilsdon 2025-04-17 15:59:58 -07:00
parent f27804f4f9
commit d86da0e399
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
servers/slack/main.py
View File

@ -119,19 +119,19 @@ class SlackClient:
async def get_channels(self, args: ListChannelsArgs) -> Dict[str, Any]: async def get_channels(self, args: ListChannelsArgs) -> Dict[str, Any]:
limit = args.limit limit = args.limit
cursor = args.cursor cursor = args.cursor
async def fetch_channel_with_history(channel_id: str) -> Dict[str, Any]: async def fetch_channel_with_history(channel_id: str) -> Dict[str, Any]:
# First get channel info # First get channel info
channel_info = await self._request("GET", "conversations.info", params={"channel": channel_id}) channel_info = await self._request("GET", "conversations.info", params={"channel": channel_id})
if not channel_info.get("ok") or channel_info.get("channel", {}).get("is_archived"): if not channel_info.get("ok") or channel_info.get("channel", {}).get("is_archived"):
return None return None
channel_data = channel_info["channel"] channel_data = channel_info["channel"]
# Then get channel history # Then get channel history
try: try:
history = await self._request( history = await self._request(
"GET", "GET",
"conversations.history", "conversations.history",
params={ params={
"channel": channel_id, "channel": channel_id,
@ -144,7 +144,7 @@ class SlackClient:
except Exception as e: except Exception as e:
print(f"Error fetching history for channel {channel_id}: {e}") print(f"Error fetching history for channel {channel_id}: {e}")
channel_data["history"] = [] channel_data["history"] = []
return channel_data return channel_data
if PREDEFINED_CHANNEL_IDS: if PREDEFINED_CHANNEL_IDS:
@ -155,7 +155,7 @@ class SlackClient:
channels_info.append(channel_data) channels_info.append(channel_data)
except Exception as e: except Exception as e:
print(f"Could not fetch info for predefined channel {channel_id}: {e}") print(f"Could not fetch info for predefined channel {channel_id}: {e}")
return { return {
"ok": True, "ok": True,
"channels": channels_info, "channels": channels_info,
@ -171,12 +171,12 @@ class SlackClient:
} }
if cursor: if cursor:
params["cursor"] = cursor params["cursor"] = cursor
channels_list = await self._request("GET", "conversations.list", params=params) channels_list = await self._request("GET", "conversations.list", params=params)
if not channels_list.get("ok"): if not channels_list.get("ok"):
return channels_list return channels_list
# Then fetch history for each channel # Then fetch history for each channel
channels_with_history = [] channels_with_history = []
for channel in channels_list["channels"]: for channel in channels_list["channels"]:
@ -186,7 +186,7 @@ class SlackClient:
except Exception as e: except Exception as e:
print(f"Error fetching history for channel {channel['id']}: {e}") print(f"Error fetching history for channel {channel['id']}: {e}")
channels_with_history.append(channel) # Fall back to channel info without history channels_with_history.append(channel) # Fall back to channel info without history
return { return {
"ok": True, "ok": True,
"channels": channels_with_history, "channels": channels_with_history,
@ -289,7 +289,7 @@ for tool_name, config in TOOL_MAPPING.items():
method=config["method"], method=config["method"],
args_model=config["args_model"] args_model=config["args_model"]
) )
app.post( app.post(
f"/{tool_name}", f"/{tool_name}",
response_model=ToolResponse, response_model=ToolResponse,