From fa8baf802285f28896e05212ffa6766d0e272aac Mon Sep 17 00:00:00 2001
From: localvar <localvar@hotmail.com>
Date: Thu, 16 Jan 2020 16:58:13 +0800
Subject: [PATCH] subscribe: remove testing code from python connector

---
 src/connector/python/linux/python2/taos/subscription.py   | 2 +-
 src/connector/python/linux/python3/taos/subscription.py   | 2 +-
 src/connector/python/windows/python2/taos/subscription.py | 2 +-
 src/connector/python/windows/python3/taos/subscription.py | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/connector/python/linux/python2/taos/subscription.py b/src/connector/python/linux/python2/taos/subscription.py
index cbba3d59ca..2d01395532 100644
--- a/src/connector/python/linux/python2/taos/subscription.py
+++ b/src/connector/python/linux/python2/taos/subscription.py
@@ -16,13 +16,13 @@ class TDengineSubscription(object):
         
         result, fields = CTaosInterface.consume(self._sub)
         buffer = [[] for i in range(len(fields))]
-        print(buffer)
         while True:
             block, num_of_fields = CTaosInterface.fetchBlock(result, fields)
             if num_of_fields == 0: break
             for i in range(len(fields)):
                 buffer[i].extend(block[i])
 
+        self.fields = fields
         return list(map(tuple, zip(*buffer)))
 
 
diff --git a/src/connector/python/linux/python3/taos/subscription.py b/src/connector/python/linux/python3/taos/subscription.py
index 3af989a138..d3cf10d5ad 100644
--- a/src/connector/python/linux/python3/taos/subscription.py
+++ b/src/connector/python/linux/python3/taos/subscription.py
@@ -16,13 +16,13 @@ class TDengineSubscription(object):
         
         result, fields = CTaosInterface.consume(self._sub)
         buffer = [[] for i in range(len(fields))]
-        print(buffer)
         while True:
             block, num_of_fields = CTaosInterface.fetchBlock(result, fields)
             if num_of_fields == 0: break
             for i in range(len(fields)):
                 buffer[i].extend(block[i])
 
+        self.fields = fields
         return list(map(tuple, zip(*buffer)))
 
 
diff --git a/src/connector/python/windows/python2/taos/subscription.py b/src/connector/python/windows/python2/taos/subscription.py
index 3af989a138..d3cf10d5ad 100644
--- a/src/connector/python/windows/python2/taos/subscription.py
+++ b/src/connector/python/windows/python2/taos/subscription.py
@@ -16,13 +16,13 @@ class TDengineSubscription(object):
         
         result, fields = CTaosInterface.consume(self._sub)
         buffer = [[] for i in range(len(fields))]
-        print(buffer)
         while True:
             block, num_of_fields = CTaosInterface.fetchBlock(result, fields)
             if num_of_fields == 0: break
             for i in range(len(fields)):
                 buffer[i].extend(block[i])
 
+        self.fields = fields
         return list(map(tuple, zip(*buffer)))
 
 
diff --git a/src/connector/python/windows/python3/taos/subscription.py b/src/connector/python/windows/python3/taos/subscription.py
index 3af989a138..d3cf10d5ad 100644
--- a/src/connector/python/windows/python3/taos/subscription.py
+++ b/src/connector/python/windows/python3/taos/subscription.py
@@ -16,13 +16,13 @@ class TDengineSubscription(object):
         
         result, fields = CTaosInterface.consume(self._sub)
         buffer = [[] for i in range(len(fields))]
-        print(buffer)
         while True:
             block, num_of_fields = CTaosInterface.fetchBlock(result, fields)
             if num_of_fields == 0: break
             for i in range(len(fields)):
                 buffer[i].extend(block[i])
 
+        self.fields = fields
         return list(map(tuple, zip(*buffer)))
 
 
-- 
GitLab