From 2d9abbc10097c183e5a8f721c867f2c38558b62b Mon Sep 17 00:00:00 2001
From: felixhjh <852142024@qq.com>
Date: Wed, 24 Nov 2021 07:53:36 +0000
Subject: [PATCH] add init success print

---
 python/pipeline/dag.py             | 1 +
 python/pipeline/operator.py        | 1 +
 python/pipeline/pipeline_server.py | 1 +
 3 files changed, 3 insertions(+)

diff --git a/python/pipeline/dag.py b/python/pipeline/dag.py
index 3f2d104e..138a2bac 100644
--- a/python/pipeline/dag.py
+++ b/python/pipeline/dag.py
@@ -508,6 +508,7 @@ class DAG(object):
         init_helper(self, request_name, response_op, use_profile, is_thread_op,
                     channel_size, build_dag_each_worker, tracer,
                     channel_recv_frist_arrive)
+        print("[DAG] Succ init")
         _LOGGER.info("[DAG] Succ init")
 
     @staticmethod
diff --git a/python/pipeline/operator.py b/python/pipeline/operator.py
index 5f4112b8..1950d4c9 100644
--- a/python/pipeline/operator.py
+++ b/python/pipeline/operator.py
@@ -1515,6 +1515,7 @@ class Op(object):
                 self.init_op() 
         
         init_helper(self, is_thread_op, concurrency_idx)
+        print("[OP Object] init success")
         # use a separate TimeProfiler per thread or process
         profiler = TimeProfiler()
         profiler.enable(True)
diff --git a/python/pipeline/pipeline_server.py b/python/pipeline/pipeline_server.py
index 452bb368..54a16c94 100644
--- a/python/pipeline/pipeline_server.py
+++ b/python/pipeline/pipeline_server.py
@@ -55,6 +55,7 @@ class PipelineServicer(pipeline_service_pb2_grpc.PipelineServiceServicer):
         init_res = init_helper(self, name, response_op, dag_conf, worker_idx)
         if init_res[1].err_no != CustomExceptionCode.OK.value :
             raise CustomException(CustomExceptionCode.INIT_ERROR, "pipeline server init error")
+        print("[PipelineServicer] succ init")
         _LOGGER.info("[PipelineServicer] succ init")
 
     def inference(self, request, context):
-- 
GitLab