fix latest_timestamp not go when no record

foolcage · Aug 2, 2018 · 4d8c7b9 · 4d8c7b9
1 parent 03af3aa
commit 4d8c7b9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fooltrader/datasource/eos.py b/fooltrader/datasource/eos.py
@@ -79,6 +79,8 @@ def eos_ram_to_kafka():
 
         logger.info("start_date:{},end_date:{}".format(start_date, end_date))
 
+        latest_timestamp = end_date
+
         for item in ram_trade.find(condition):
             tick = to_tick(item)