def run_concurrency_test()

in configurations/redshift-performance-test.py [0:0]

• 16 lines of code
• 4 McCabe index (conditional complexity)

def run_concurrency_test(number_of_parallel_sessions):
    engine=connect_to_redshift(REDSHIFT_CLUSTER_ENDPOINT,REDSHIFT_USER_NAME)
    start_time = time.time()
    try:
        with ThreadPoolExecutor(max_workers=number_of_parallel_sessions) as executor:
            futures = []
            for _ in range(number_of_parallel_sessions):
                futures.append(executor.submit(
                    get_sql, engine, number_of_parallel_sessions))
            for future in as_completed(futures):
                rs = future.result()

    except Exception as e:
        raise e
    elapsed_time_in_secs = (time.time() - start_time)
    print("--- %s seconds ---" % elapsed_time_in_secs)
    return elapsed_time_in_secs