Skip to content

Commit 322fd10

Browse files
committed
Merge branch 'stream-term-errpr' into develop
2 parents 8c82b14 + 8a03b17 commit 322fd10

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

nitric/faas.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
SubscriptionWorker,
4242
ScheduleRate,
4343
)
44+
import grpclib
4445
import asyncio
4546
from abc import ABC
4647

@@ -510,6 +511,8 @@ async def _run(self):
510511
continue
511512
if request_channel.done():
512513
break
514+
except grpclib.exceptions.StreamTerminatedError:
515+
print("stream from Membrane closed, closing client stream")
513516
except asyncio.CancelledError:
514517
# Membrane has closed stream after init
515518
print("stream from Membrane closed, closing client stream")

0 commit comments

Comments
 (0)