From eda63a84ce5c11516185458fc218fbaab41e2694 Mon Sep 17 00:00:00 2001
From: barrierye <barriery@qq.com>
Date: Mon, 6 Jul 2020 21:05:56 +0800
Subject: [PATCH] update operator

---
 python/pipeline/operator.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/python/pipeline/operator.py b/python/pipeline/operator.py
index 29c37f2c..0f34fc43 100644
--- a/python/pipeline/operator.py
+++ b/python/pipeline/operator.py
@@ -197,7 +197,7 @@ class Op(object):
             threads.append(t)
         return threads
 
-    def init_op(self, concurrency_idx):
+    def init_op(self):
         pass
 
     def _run_preprocess(self, parsed_data, data_id, log_func):
-- 
GitLab