diff --git a/python/pipeline/dag.py b/python/pipeline/dag.py
index 3f2d104e959afd34cb10f90205afaac71ebba6ae..138a2bac132dd3e8afc8209554efb7da02e32853 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 5f4112b8d8ee238431fb2c0fbb1ea80d7b725026..1950d4c9689711c8be39d9164b5484e54d59b97e 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 452bb36853f95ed9a63527fe7cc7701ca436efc6..54a16c94882a903e37b090c2c02bb88cb8a5a4a2 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):