diff --git a/python/pipeline/pipeline_server.py b/python/pipeline/pipeline_server.py index 4569e55a55f3a009406a1bcad1b8e809e8d3501d..9963a2eb69034a8f936c97c658344c09009b3c66 100644 --- a/python/pipeline/pipeline_server.py +++ b/python/pipeline/pipeline_server.py @@ -228,6 +228,10 @@ class PipelineServer(object): return use_ops, succ_ops_of_use_op use_ops, out_degree_ops = get_use_ops(response_op) + if len(use_ops) <= 1: + raise Exception( + "Besides RequestOp and ResponseOp, there should be at least one Op in DAG." + ) name2op = {op.name: op for op in use_ops} out_degree_num = {