chore: improve usage of striping prefix or suffix of string with Ruff 0.6.5 (#8392)
This commit is contained in:
@@ -49,8 +49,7 @@ class HuggingfaceTeiRerankModel(RerankModel):
|
||||
return RerankResult(model=model, docs=[])
|
||||
server_url = credentials["server_url"]
|
||||
|
||||
if server_url.endswith("/"):
|
||||
server_url = server_url[:-1]
|
||||
server_url = server_url.removesuffix("/")
|
||||
|
||||
try:
|
||||
results = TeiHelper.invoke_rerank(server_url, query, docs)
|
||||
|
||||
@@ -42,8 +42,7 @@ class HuggingfaceTeiTextEmbeddingModel(TextEmbeddingModel):
|
||||
"""
|
||||
server_url = credentials["server_url"]
|
||||
|
||||
if server_url.endswith("/"):
|
||||
server_url = server_url[:-1]
|
||||
server_url = server_url.removesuffix("/")
|
||||
|
||||
# get model properties
|
||||
context_size = self._get_context_size(model, credentials)
|
||||
@@ -119,8 +118,7 @@ class HuggingfaceTeiTextEmbeddingModel(TextEmbeddingModel):
|
||||
num_tokens = 0
|
||||
server_url = credentials["server_url"]
|
||||
|
||||
if server_url.endswith("/"):
|
||||
server_url = server_url[:-1]
|
||||
server_url = server_url.removesuffix("/")
|
||||
|
||||
batch_tokens = TeiHelper.invoke_tokenize(server_url, texts)
|
||||
num_tokens = sum(len(tokens) for tokens in batch_tokens)
|
||||
|
||||
@@ -48,8 +48,7 @@ class JinaRerankModel(RerankModel):
|
||||
return RerankResult(model=model, docs=[])
|
||||
|
||||
base_url = credentials.get("base_url", "https://api.jina.ai/v1")
|
||||
if base_url.endswith("/"):
|
||||
base_url = base_url[:-1]
|
||||
base_url = base_url.removesuffix("/")
|
||||
|
||||
try:
|
||||
response = httpx.post(
|
||||
|
||||
@@ -44,8 +44,7 @@ class JinaTextEmbeddingModel(TextEmbeddingModel):
|
||||
raise CredentialsValidateFailedError("api_key is required")
|
||||
|
||||
base_url = credentials.get("base_url", self.api_base)
|
||||
if base_url.endswith("/"):
|
||||
base_url = base_url[:-1]
|
||||
base_url = base_url.removesuffix("/")
|
||||
|
||||
url = base_url + "/embeddings"
|
||||
headers = {"Authorization": "Bearer " + api_key, "Content-Type": "application/json"}
|
||||
|
||||
@@ -30,8 +30,7 @@ class SiliconflowRerankModel(RerankModel):
|
||||
return RerankResult(model=model, docs=[])
|
||||
|
||||
base_url = credentials.get("base_url", "https://api.siliconflow.cn/v1")
|
||||
if base_url.endswith("/"):
|
||||
base_url = base_url[:-1]
|
||||
base_url = base_url.removesuffix("/")
|
||||
try:
|
||||
response = httpx.post(
|
||||
base_url + "/rerank",
|
||||
|
||||
@@ -459,8 +459,7 @@ class XinferenceAILargeLanguageModel(LargeLanguageModel):
|
||||
if "server_url" not in credentials:
|
||||
raise CredentialsValidateFailedError("server_url is required in credentials")
|
||||
|
||||
if credentials["server_url"].endswith("/"):
|
||||
credentials["server_url"] = credentials["server_url"][:-1]
|
||||
credentials["server_url"] = credentials["server_url"].removesuffix("/")
|
||||
|
||||
api_key = credentials.get("api_key") or "abc"
|
||||
|
||||
|
||||
@@ -50,8 +50,7 @@ class XinferenceRerankModel(RerankModel):
|
||||
server_url = credentials["server_url"]
|
||||
model_uid = credentials["model_uid"]
|
||||
api_key = credentials.get("api_key")
|
||||
if server_url.endswith("/"):
|
||||
server_url = server_url[:-1]
|
||||
server_url = server_url.removesuffix("/")
|
||||
auth_headers = {"Authorization": f"Bearer {api_key}"} if api_key else {}
|
||||
|
||||
params = {"documents": docs, "query": query, "top_n": top_n, "return_documents": True}
|
||||
@@ -98,8 +97,7 @@ class XinferenceRerankModel(RerankModel):
|
||||
if "/" in credentials["model_uid"] or "?" in credentials["model_uid"] or "#" in credentials["model_uid"]:
|
||||
raise CredentialsValidateFailedError("model_uid should not contain /, ?, or #")
|
||||
|
||||
if credentials["server_url"].endswith("/"):
|
||||
credentials["server_url"] = credentials["server_url"][:-1]
|
||||
credentials["server_url"] = credentials["server_url"].removesuffix("/")
|
||||
|
||||
# initialize client
|
||||
client = Client(
|
||||
|
||||
@@ -45,8 +45,7 @@ class XinferenceSpeech2TextModel(Speech2TextModel):
|
||||
if "/" in credentials["model_uid"] or "?" in credentials["model_uid"] or "#" in credentials["model_uid"]:
|
||||
raise CredentialsValidateFailedError("model_uid should not contain /, ?, or #")
|
||||
|
||||
if credentials["server_url"].endswith("/"):
|
||||
credentials["server_url"] = credentials["server_url"][:-1]
|
||||
credentials["server_url"] = credentials["server_url"].removesuffix("/")
|
||||
|
||||
# initialize client
|
||||
client = Client(
|
||||
@@ -116,8 +115,7 @@ class XinferenceSpeech2TextModel(Speech2TextModel):
|
||||
server_url = credentials["server_url"]
|
||||
model_uid = credentials["model_uid"]
|
||||
api_key = credentials.get("api_key")
|
||||
if server_url.endswith("/"):
|
||||
server_url = server_url[:-1]
|
||||
server_url = server_url.removesuffix("/")
|
||||
auth_headers = {"Authorization": f"Bearer {api_key}"} if api_key else {}
|
||||
|
||||
try:
|
||||
|
||||
@@ -45,8 +45,7 @@ class XinferenceTextEmbeddingModel(TextEmbeddingModel):
|
||||
server_url = credentials["server_url"]
|
||||
model_uid = credentials["model_uid"]
|
||||
api_key = credentials.get("api_key")
|
||||
if server_url.endswith("/"):
|
||||
server_url = server_url[:-1]
|
||||
server_url = server_url.removesuffix("/")
|
||||
auth_headers = {"Authorization": f"Bearer {api_key}"} if api_key else {}
|
||||
|
||||
try:
|
||||
@@ -118,8 +117,7 @@ class XinferenceTextEmbeddingModel(TextEmbeddingModel):
|
||||
|
||||
if extra_args.max_tokens:
|
||||
credentials["max_tokens"] = extra_args.max_tokens
|
||||
if server_url.endswith("/"):
|
||||
server_url = server_url[:-1]
|
||||
server_url = server_url.removesuffix("/")
|
||||
|
||||
client = Client(
|
||||
base_url=server_url,
|
||||
|
||||
@@ -73,8 +73,7 @@ class XinferenceText2SpeechModel(TTSModel):
|
||||
if "/" in credentials["model_uid"] or "?" in credentials["model_uid"] or "#" in credentials["model_uid"]:
|
||||
raise CredentialsValidateFailedError("model_uid should not contain /, ?, or #")
|
||||
|
||||
if credentials["server_url"].endswith("/"):
|
||||
credentials["server_url"] = credentials["server_url"][:-1]
|
||||
credentials["server_url"] = credentials["server_url"].removesuffix("/")
|
||||
|
||||
extra_param = XinferenceHelper.get_xinference_extra_parameter(
|
||||
server_url=credentials["server_url"],
|
||||
@@ -189,8 +188,7 @@ class XinferenceText2SpeechModel(TTSModel):
|
||||
:param voice: model timbre
|
||||
:return: text translated to audio file
|
||||
"""
|
||||
if credentials["server_url"].endswith("/"):
|
||||
credentials["server_url"] = credentials["server_url"][:-1]
|
||||
credentials["server_url"] = credentials["server_url"].removesuffix("/")
|
||||
|
||||
try:
|
||||
api_key = credentials.get("api_key")
|
||||
|
||||
@@ -127,8 +127,7 @@ class SSELineParser:
|
||||
|
||||
field, _p, value = line.partition(":")
|
||||
|
||||
if value.startswith(" "):
|
||||
value = value[1:]
|
||||
value = value.removeprefix(" ")
|
||||
if field == "data":
|
||||
self._data.append(value)
|
||||
elif field == "event":
|
||||
|
||||
Reference in New Issue
Block a user