Compare commits

..

1 Commits

Author SHA1 Message Date
Rob Ballantyne b8377c4081 Set cost to 100 2025-08-28 16:13:17 +01:00
3 changed files with 6 additions and 11 deletions
+2 -8
View File
@@ -11,7 +11,7 @@ from functools import cached_property
from distutils.util import strtobool
from anyio import open_file
from aiohttp import web, ClientResponse, ClientSession, ClientConnectorError, ClientTimeout, TCPConnector
from aiohttp import web, ClientResponse, ClientSession, ClientConnectorError
import requests
from Crypto.Signature import pkcs1_15
@@ -75,13 +75,7 @@ class Backend:
@cached_property
def session(self):
log.debug(f"starting session with {self.model_server_url}")
connector = TCPConnector(
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)
return ClientSession(self.model_server_url)
def create_handler(
self,
+3 -2
View File
@@ -13,8 +13,9 @@ with open("workers/comfyui/misc/test_prompts.txt", "r") as f:
test_prompts = f.readlines()
def count_workload() -> float:
# Always 1.0 where there is a single instance of ComfyUI handling requests
return 1.0
# Always 100.0 where there is a single instance of ComfyUI handling requests
# Results will indicate % or a job completed per second. Avoids sub 0.1 sec performance indication
return 100.0
@dataclasses.dataclass
class ComfyWorkflowData(ApiPayload):
+1 -1
View File
@@ -70,7 +70,7 @@ class ComfyWorkflowHandler(EndpointHandler[ComfyWorkflowData]):
@property
def healthcheck_endpoint(self) -> Optional[str]:
return None
return "/health"
@classmethod
def payload_cls(cls) -> Type[ComfyWorkflowData]: