Permalink
Switch branches/tags
Nothing to show
Find file Copy path
5e60fd2 Aug 25, 2017
1 contributor

Users who have contributed to this file

21 lines (15 sloc) 485 Bytes
import threading
from benchmark.runner import JobManager
from configs import LOGGER
from utils.argparser import get_args_cli
from utils.helper import UploadS3Thread
def start_s3_sync():
stop_flag = threading.Event()
upload_s3_thread = UploadS3Thread(stop_flag)
upload_s3_thread.start()
if __name__ == "__main__":
arg_dict = get_args_cli()
LOGGER.info('received task with args: %s' % arg_dict)
start_s3_sync()
jm = JobManager(**arg_dict)
jm.start()