Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| b8377c4081 |
+2
-8
@@ -11,7 +11,7 @@ from functools import cached_property
|
|||||||
from distutils.util import strtobool
|
from distutils.util import strtobool
|
||||||
|
|
||||||
from anyio import open_file
|
from anyio import open_file
|
||||||
from aiohttp import web, ClientResponse, ClientSession, ClientConnectorError, ClientTimeout, TCPConnector
|
from aiohttp import web, ClientResponse, ClientSession, ClientConnectorError
|
||||||
|
|
||||||
import requests
|
import requests
|
||||||
from Crypto.Signature import pkcs1_15
|
from Crypto.Signature import pkcs1_15
|
||||||
@@ -75,13 +75,7 @@ class Backend:
|
|||||||
@cached_property
|
@cached_property
|
||||||
def session(self):
|
def session(self):
|
||||||
log.debug(f"starting session with {self.model_server_url}")
|
log.debug(f"starting session with {self.model_server_url}")
|
||||||
connector = TCPConnector(
|
return ClientSession(self.model_server_url)
|
||||||
force_close=True, # Required for long running jobs
|
|
||||||
enable_cleanup_closed=True,
|
|
||||||
)
|
|
||||||
|
|
||||||
timeout = ClientTimeout(total=None)
|
|
||||||
return ClientSession(self.model_server_url, timeout=timeout, connector=connector)
|
|
||||||
|
|
||||||
def create_handler(
|
def create_handler(
|
||||||
self,
|
self,
|
||||||
|
|||||||
@@ -13,8 +13,9 @@ with open("workers/comfyui/misc/test_prompts.txt", "r") as f:
|
|||||||
test_prompts = f.readlines()
|
test_prompts = f.readlines()
|
||||||
|
|
||||||
def count_workload() -> float:
|
def count_workload() -> float:
|
||||||
# Always 1.0 where there is a single instance of ComfyUI handling requests
|
# Always 100.0 where there is a single instance of ComfyUI handling requests
|
||||||
return 1.0
|
# Results will indicate % or a job completed per second. Avoids sub 0.1 sec performance indication
|
||||||
|
return 100.0
|
||||||
|
|
||||||
@dataclasses.dataclass
|
@dataclasses.dataclass
|
||||||
class ComfyWorkflowData(ApiPayload):
|
class ComfyWorkflowData(ApiPayload):
|
||||||
|
|||||||
@@ -70,7 +70,7 @@ class ComfyWorkflowHandler(EndpointHandler[ComfyWorkflowData]):
|
|||||||
|
|
||||||
@property
|
@property
|
||||||
def healthcheck_endpoint(self) -> Optional[str]:
|
def healthcheck_endpoint(self) -> Optional[str]:
|
||||||
return None
|
return "/health"
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def payload_cls(cls) -> Type[ComfyWorkflowData]:
|
def payload_cls(cls) -> Type[ComfyWorkflowData]:
|
||||||
|
|||||||
Reference in New Issue
Block a user