From 2dad63e0b3cf7381dffb0d824d64d85a6ed84092 Mon Sep 17 00:00:00 2001
From: barrierye <barriery@qq.com>
Date: Mon, 10 Aug 2020 19:19:03 +0800
Subject: [PATCH] udpate code

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

diff --git a/python/pipeline/dag.py b/python/pipeline/dag.py
index bde87cfe..b115bdb3 100644
--- a/python/pipeline/dag.py
+++ b/python/pipeline/dag.py
@@ -285,7 +285,7 @@ class DAGExecutor(object):
             end_call = self._profiler.record("call_{}#DAG_1".format(data_id))
 
         if self._tracer is not None:
-            trace_buffer.put_nowait({
+            trace_buffer.put({
                 "name": "DAG",
                 "id": data_id,
                 "succ": resp_channeldata.ecode == ChannelDataEcode.OK.value,
-- 
GitLab