diff --git a/quixstreams/core/stream/functions/base.py b/quixstreams/core/stream/functions/base.py index 24438ef13..b39d46d0b 100644 --- a/quixstreams/core/stream/functions/base.py +++ b/quixstreams/core/stream/functions/base.py @@ -39,7 +39,7 @@ def _resolve_branching(self, *child_executors: VoidExecutor) -> VoidExecutor: is returned as is. """ if not child_executors: - raise TypeError("At least one executor is required") + raise ValueError("At least one executor is required") if len(child_executors) > 1: