diff --git a/python/pipeline/operator.py b/python/pipeline/operator.py
index accfdfce7a50643a5b5fb2ae74baf03d5b13f941..29c37f2c64356bde8ae1e93635a7bff48424264c 100644
--- a/python/pipeline/operator.py
+++ b/python/pipeline/operator.py
@@ -339,14 +339,15 @@ class Op(object):
             os._exit(-1)
 
         # init op
+        self.concurrency_idx = concurrency_idx
         try:
             if use_multithread:
                 with self._for_init_op_lock:
                     if not self._succ_init_op:
-                        self.init_op(concurrency_idx)
+                        self.init_op()
                         self._succ_init_op = True
             else:
-                self.init_op(concurrency_idx)
+                self.init_op()
         except Exception as e:
             _LOGGER.error(log(e))
             os._exit(-1)
@@ -424,8 +425,9 @@ class RequestOp(Op):
         super(RequestOp, self).__init__(
             name="@G", input_ops=[], concurrency=concurrency)
         # init op
+        self.concurrency_idx = concurrency_idx
         try:
-            self.init_op(0)
+            self.init_op()
         except Exception as e:
             _LOGGER.error(e)
             os._exit(-1)
@@ -449,8 +451,9 @@ 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(0)
+            self.init_op()
         except Exception as e:
             _LOGGER.error(e)
             os._exit(-1)