From 1738046837ac58ec017dbfe556da9e972bfd4240 Mon Sep 17 00:00:00 2001
From: barrierye <barriery@qq.com>
Date: Sun, 5 Jul 2020 02:47:23 +0800
Subject: [PATCH] rename globel_resp_dict to fetch_buffer in DAGExecutor

---
 python/pipeline/dag.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/python/pipeline/dag.py b/python/pipeline/dag.py
index 3fdb9b47..83c30393 100644
--- a/python/pipeline/dag.py
+++ b/python/pipeline/dag.py
@@ -53,7 +53,7 @@ class DAGExecutor(object):
 
         self._id_lock = threading.Lock()
         self._cv = threading.Condition()
-        self._globel_resp_dict = {}
+        self._fetch_buffer = {}
         self._id_counter = 0
         self._reset_max_id = 1000000000000000000
         self._is_run = False
@@ -106,15 +106,15 @@ class DAGExecutor(object):
                               format(type(channeldata))))
             with self._cv:
                 data_id = channeldata.id
-                self._globel_resp_dict[data_id] = channeldata
+                self._fetch_buffer[data_id] = channeldata
                 self._cv.notify_all()
 
     def _get_channeldata_from_fetch_buffer(self, data_id):
         resp = None
         with self._cv:
-            while data_id not in self._globel_resp_dict:
+            while data_id not in self._fetch_buffer:
                 self._cv.wait()
-            resp = self._globel_resp_dict.pop(data_id)
+            resp = self._fetch_buffer.pop(data_id)
             self._cv.notify_all()
         return resp
 
-- 
GitLab