🐞 fix: don't break when result is None

mic1on · Nov 22, 2023 · ced1b58 · ced1b58
1 parent 3406163
commit ced1b58
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/onestep/worker.py b/src/onestep/worker.py
@@ -52,8 +52,10 @@ def run(self):
                 self.shutdown()
                 break
             for result in self.broker.consume():
-                if self._shutdown or result is None:
+                if self._shutdown:
                     break
+                if result is None:
+                    continue
                 messages = (
                     result
                     if isinstance(result, Iterable)