Fixed gcm3 - writing and reading points.

klokantech · Sep 12, 2017 · f219e0c · f219e0c
1 parent 5e65df0
commit f219e0c
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/cloudwrapper/gcm3.py b/cloudwrapper/gcm3.py
@@ -154,9 +154,11 @@ def read(self, startTime=None, endTime=None, pageSize=10):
             ).select_interval(
                 end_time=endTime,
                 start_time=startTime)
-            return list(query.iter(page_size=pageSize))
+            for ts in query.iter(page_size=pageSize):
+                for p in ts.points:
+                    yield p
         except:
-            return []
+            pass
 
 
     def _addPoint(self, value, startTime=None, endTime=None):
@@ -226,7 +228,7 @@ def write(self, value, startTime=None, endTime=None, metricLabels={}):
                     labels=metricLabels
                 )
                 # Point is dictionary which corresponds with write_points args
-                for point in self.points():
+                for point in self.points:
                     self.client.write_point(metric, resource, **point)
                 self.points = []
                 return True