indpnday

import riak
from concurrent.futures import ThreadPoolExecutor, as_completed
from collections import deque
import time
import signal


def main_function():
	client = riak.RiakClient(protocol='pbc', host='127.0.0.1', pbc_port=8097)
	max_loops = 100