diff --git a/examples/python-operator-dataflow/object_detection.py b/examples/python-operator-dataflow/object_detection.py index fd103f86..15fd5f76 100755 --- a/examples/python-operator-dataflow/object_detection.py +++ b/examples/python-operator-dataflow/object_detection.py @@ -29,6 +29,7 @@ class Operator: ) -> DoraStatus: if dora_event["type"] == "INPUT": return self.on_input(dora_event, send_output) + return DoraStatus.CONTINUE def on_input( self, diff --git a/examples/python-operator-dataflow/plot.py b/examples/python-operator-dataflow/plot.py index 6c95eae8..dc0c4d63 100755 --- a/examples/python-operator-dataflow/plot.py +++ b/examples/python-operator-dataflow/plot.py @@ -33,6 +33,7 @@ class Operator: ) -> DoraStatus: if dora_event["type"] == "INPUT": return self.on_input(dora_event, send_output) + return DoraStatus.CONTINUE def on_input( self,