updat pointers according to the number fetched urls

2016-04-25 09:12:29 +08:00 · 2016-04-25 09:12:29 +08:00 · dc86a11aff
parent 8fc187a622
commit dc86a11aff
1 changed files with 1 additions and 1 deletions
--- a/producer.py
+++ b/producer.py
@ -36,7 +36,7 @@ def start():
 	    for url in urls_added:
 		r.rpush("repo_urls","%d-%s"%(url[0],url[1]))
 		cursor.execute(sql_update_pushtime,(time.time(),url[0]))
-	    cursor.execute(sql_update_pointer,(last_id + patch_size,))
+	    cursor.execute(sql_update_pointer,(last_id + len(urls_added),))
 	    conn.commit()
 	else:
 	    logger.info(">>enough urls")