From 4d8c7b98db0d3fd54565073978fcad9ad1bb52f0 Mon Sep 17 00:00:00 2001
From: foolcage <5533061@qq.com>
Date: Thu, 2 Aug 2018 21:33:51 +0800
Subject: [PATCH] fix latest_timestamp not go when no record

---
 fooltrader/datasource/eos.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/fooltrader/datasource/eos.py b/fooltrader/datasource/eos.py
index 3daac37..35f6507 100644
--- 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)