|
@@ -240,7 +240,7 @@ def push(pool_url, data, secret):
|
|
|
def puller(queue, source, source_type, multiplier):
|
|
def puller(queue, source, source_type, multiplier):
|
|
|
while True:
|
|
while True:
|
|
|
try:
|
|
try:
|
|
|
- data = sample(source, source_type, multiplier=1)
|
|
|
|
|
|
|
+ data = sample(source, source_type, multiplier)
|
|
|
except KeyboardInterrupt:
|
|
except KeyboardInterrupt:
|
|
|
logger.info("Interrupted by user.")
|
|
logger.info("Interrupted by user.")
|
|
|
|
|
|
