chg: More reasonable insert chunks
parent
c20175fce6
commit
4a2db70a26
|
@ -24,7 +24,7 @@ class DatabaseInsert():
|
||||||
while True:
|
while True:
|
||||||
if shutdown_requested():
|
if shutdown_requested():
|
||||||
break
|
break
|
||||||
uuids = self.redis_sanitized.spop('to_insert', 1000)
|
uuids = self.redis_sanitized.spop('to_insert', 100)
|
||||||
if not uuids:
|
if not uuids:
|
||||||
break
|
break
|
||||||
p = self.redis_sanitized.pipeline(transaction=False)
|
p = self.redis_sanitized.pipeline(transaction=False)
|
||||||
|
|
Loading…
Reference in New Issue