Skip to content

Commit 11a6bb8

Browse files
author
xiongjianqiang
committed
Bug fix
1 parent caa9a7e commit 11a6bb8

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

mongo_sync/oplog_manager.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,9 @@ def get_cursor():
110110
sliced = list(cursor)
111111

112112
if not sliced:
113+
LOG.info('No more new records. Sleep...')
113114
time.sleep(10)
115+
return
114116

115117
self._last_ts = sliced[-1]['ts']
116118
self.save_sliced(sliced)

0 commit comments

Comments
 (0)