diff --git a/producer.py b/producer.py index 47aa09e..05020f9 100755 --- 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")