fix(server): ServiceUnavailable init failed
@@ -60,7 +60,9 @@ class RunnerAppFactory(BaseAppFactory):
self.dispatchers[method.name] = CorkDispatcher(
max_latency_in_ms=method.max_latency_ms,
max_batch_size=method.max_batch_size,
- fallback=ServiceUnavailable,
+ fallback=functools.partial(
+ ServiceUnavailable, message="process is overloaded"
+ ),
)
@property
