diff --git a/python/pipeline/operator.py b/python/pipeline/operator.py index 0f34fc4336beb2be429cb7af3829e365cac8718d..507807c61566e9f620399082fea6a42efd0d9b2b 100644 --- a/python/pipeline/operator.py +++ b/python/pipeline/operator.py @@ -425,7 +425,6 @@ class RequestOp(Op): super(RequestOp, self).__init__( name="@G", input_ops=[], concurrency=concurrency) # init op - self.concurrency_idx = concurrency_idx try: self.init_op() except Exception as e: @@ -451,7 +450,6 @@ class ResponseOp(Op): super(ResponseOp, self).__init__( name="@R", input_ops=input_ops, concurrency=concurrency) # init op - self.concurrency_idx = concurrency_idx try: self.init_op() except Exception as e: