Skip to content

Commit 7b8064b

Browse files
Ignore exceptions in all tasks (#20)
1 parent f2ce394 commit 7b8064b

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

src/zmq_anyio/_socket.py

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,9 @@ async def trigger_timeout():
125125
watcher.set_result(None)
126126

127127
if not future.done():
128-
timeout_handle = create_task(trigger_timeout(), task_group)
128+
timeout_handle = create_task(
129+
trigger_timeout(), task_group, exception_handler=ignore_exceptions
130+
)
129131

130132
def cancel_timeout(f):
131133
timeout_handle.cancel()
@@ -567,7 +569,9 @@ async def call_later():
567569
await sleep(delay)
568570
callback()
569571

570-
return create_task(call_later(), self._task_group)
572+
return create_task(
573+
call_later(), self._task_group, exception_handler=ignore_exceptions
574+
)
571575

572576
@staticmethod
573577
def _remove_finished_future(future, event_list, event=None):
@@ -861,7 +865,11 @@ async def _start(self, *, task_status: TaskStatus[None]):
861865
self.started.set()
862866
try:
863867
while True:
864-
wait_stopped_task = create_task(self.stopped.wait(), self._task_group)
868+
wait_stopped_task = create_task(
869+
self.stopped.wait(),
870+
self._task_group,
871+
exception_handler=ignore_exceptions,
872+
)
865873
tasks = [
866874
create_task(
867875
wait_readable(self._shadow_sock.FD), # type: ignore[arg-type]

0 commit comments

Comments
 (0)