Skip to content

Commit 486716b

Browse files
committed
Bump up pycapnp to 2.2.1
1 parent 2295a1b commit 486716b

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ dependencies = [
2121
"bidict",
2222
"cloudpickle",
2323
"psutil==7.1.3",
24-
"pycapnp==2.1.0",
24+
"pycapnp==2.2.1",
2525
"pyzmq",
2626
"sortedcontainers==2.4.0",
2727
"tblib",

src/scaler/protocol/python/status.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,11 @@ def client_to_num_of_tasks(self) -> Dict[ClientID, int]:
5555

5656
@staticmethod
5757
def new_msg(client_to_num_of_tasks: Dict[ClientID, int]) -> "ClientManagerStatus": # type: ignore[override]
58+
for client_id, num_tasks in client_to_num_of_tasks.items():
59+
try:
60+
client = client_id.decode()
61+
except:
62+
print(f"{client_id=!r}")
5863
return ClientManagerStatus(
5964
_status.ClientManagerStatus(
6065
clientToNumOfTask=[

0 commit comments

Comments
 (0)