rename globel_resp_dict to fetch_buffer in DAGExecutor

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