We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 8c82b14 + 8a03b17 commit 322fd10Copy full SHA for 322fd10
1 file changed
nitric/faas.py
@@ -41,6 +41,7 @@
41
SubscriptionWorker,
42
ScheduleRate,
43
)
44
+import grpclib
45
import asyncio
46
from abc import ABC
47
@@ -510,6 +511,8 @@ async def _run(self):
510
511
continue
512
if request_channel.done():
513
break
514
+ except grpclib.exceptions.StreamTerminatedError:
515
+ print("stream from Membrane closed, closing client stream")
516
except asyncio.CancelledError:
517
# Membrane has closed stream after init
518
print("stream from Membrane closed, closing client stream")
0 commit comments