forked from goodboy/tractor
Type check fixes
parent
7b9d410c4d
commit
41a3e6a9ca
|
@ -182,6 +182,7 @@ async def _invoke(
|
||||||
else:
|
else:
|
||||||
raise
|
raise
|
||||||
|
|
||||||
|
assert cs
|
||||||
if cs.cancelled_caught or ctx._error:
|
if cs.cancelled_caught or ctx._error:
|
||||||
|
|
||||||
# TODO: pack in ``trio.Cancelled.__traceback__`` here
|
# TODO: pack in ``trio.Cancelled.__traceback__`` here
|
||||||
|
@ -706,7 +707,7 @@ class Actor:
|
||||||
ctx = self._contexts[(actor_uid, cid)]
|
ctx = self._contexts[(actor_uid, cid)]
|
||||||
|
|
||||||
# adjust buffer size if specified
|
# adjust buffer size if specified
|
||||||
state = ctx._send_chan._state
|
state = ctx._send_chan._state # type: ignore
|
||||||
if msg_buffer_size and state.max_buffer_size != msg_buffer_size:
|
if msg_buffer_size and state.max_buffer_size != msg_buffer_size:
|
||||||
state.max_buffer_size = msg_buffer_size
|
state.max_buffer_size = msg_buffer_size
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue