add init success print

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

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)

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):