From c01a6933ee93d45779543af7d2b85b904e1e34d0 Mon Sep 17 00:00:00 2001 From: Matthew Rocklin Date: Mon, 9 Apr 2018 21:45:55 -0500 Subject: [PATCH] add try-except around sink.update --- streamz/core.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/streamz/core.py b/streamz/core.py index dec8606e..5888a188 100644 --- a/streamz/core.py +++ b/streamz/core.py @@ -508,7 +508,11 @@ def __init__(self, upstream, func, *args, **kwargs): _global_sinks.add(self) def update(self, x, who=None): - result = self.func(x, *self.args, **self.kwargs) + try: + result = self.func(x, *self.args, **self.kwargs) + except Exception: + return [] + if gen.isawaitable(result): return result else: