handler newer driver case

StreamReader/runner.py

@@ -4,7 +4,7 @@ from redistimeseries.client import Client as RedisTimeSeries
 import redis
 import time
 
-redis_host = "redis"
+redis_host = "localhost"
 redis_port = 6379
 
 rts = RedisTimeSeries(host=redis_host, port=redis_port)
@@ -28,8 +28,8 @@ while True:
             try:
                 rts.info(evnt)
             except:
-                rts.create(evnt, retentionSecs=60, labels={'event_type': evnt})
-                rts.create(evnt+"_minute", retentionSecs=0, labels={'event_type': evnt})
+                rts.create(evnt, retention_msecs=60000, labels={'event_type': evnt})
+                rts.create(evnt+"_minute", retention_msecs=0, labels={'event_type': evnt})
                 rts.createrule(evnt, evnt+"_minute", 'count', 60)
 
             rts.incrby(evnt,1)