Skip to content

Commit 5f5ec7c

Browse files
committed
add .decode(utf-8) to ident before usage
1 parent 0ac0295 commit 5f5ec7c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

ipyparallel/client/client.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1607,6 +1607,7 @@ def send_apply_request(
16071607
# possibly routed to a specific engine
16081608
if isinstance(ident, list):
16091609
ident = ident[-1]
1610+
ident = ident.decode("utf-8")
16101611
if ident in self._engines.values():
16111612
# save for later, in case of engine death
16121613
self._outstanding_dict[ident].add(msg_id)
@@ -1645,6 +1646,7 @@ def send_execute_request(
16451646
# possibly routed to a specific engine
16461647
if isinstance(ident, list):
16471648
ident = ident[-1]
1649+
ident = ident.decode("utf-8")
16481650
if ident in self._engines.values():
16491651
# save for later, in case of engine death
16501652
self._outstanding_dict[ident].add(msg_id)

0 commit comments

Comments
 (0)