Spaces:
Sleeping
Sleeping
fix: modify custom class
Browse files- services/model_handler.py +12 -4
services/model_handler.py
CHANGED
@@ -62,21 +62,29 @@ class LocalHuggingFaceModel(Model):
|
|
62 |
"""Parse the provider response delta for streaming"""
|
63 |
return delta
|
64 |
|
65 |
-
async def aresponse(self, prompt
|
66 |
"""Async response method - required abstract method"""
|
|
|
|
|
67 |
return await self.ainvoke(prompt=prompt, **kwargs)
|
68 |
|
69 |
-
async def aresponse_stream(self, prompt
|
70 |
"""Async streaming response method - required abstract method"""
|
|
|
|
|
71 |
async for chunk in self.ainvoke_stream(prompt=prompt, **kwargs):
|
72 |
yield chunk
|
73 |
|
74 |
-
def response(self, prompt
|
75 |
"""Synchronous response method - required abstract method"""
|
|
|
|
|
76 |
return self.invoke(prompt=prompt, **kwargs)
|
77 |
|
78 |
-
def response_stream(self, prompt
|
79 |
"""Synchronous streaming response method - required abstract method"""
|
|
|
|
|
80 |
for chunk in self.invoke_stream(prompt=prompt, **kwargs):
|
81 |
yield chunk
|
82 |
|
|
|
62 |
"""Parse the provider response delta for streaming"""
|
63 |
return delta
|
64 |
|
65 |
+
async def aresponse(self, prompt=None, **kwargs) -> str:
|
66 |
"""Async response method - required abstract method"""
|
67 |
+
if prompt is None:
|
68 |
+
prompt = kwargs.get('input', '')
|
69 |
return await self.ainvoke(prompt=prompt, **kwargs)
|
70 |
|
71 |
+
async def aresponse_stream(self, prompt=None, **kwargs):
|
72 |
"""Async streaming response method - required abstract method"""
|
73 |
+
if prompt is None:
|
74 |
+
prompt = kwargs.get('input', '')
|
75 |
async for chunk in self.ainvoke_stream(prompt=prompt, **kwargs):
|
76 |
yield chunk
|
77 |
|
78 |
+
def response(self, prompt=None, **kwargs) -> str:
|
79 |
"""Synchronous response method - required abstract method"""
|
80 |
+
if prompt is None:
|
81 |
+
prompt = kwargs.get('input', '')
|
82 |
return self.invoke(prompt=prompt, **kwargs)
|
83 |
|
84 |
+
def response_stream(self, prompt=None, **kwargs):
|
85 |
"""Synchronous streaming response method - required abstract method"""
|
86 |
+
if prompt is None:
|
87 |
+
prompt = kwargs.get('input', '')
|
88 |
for chunk in self.invoke_stream(prompt=prompt, **kwargs):
|
89 |
yield chunk
|
90 |
|