def METHOD_NAME(conn_cnx, db_parameters):
    """Concurrent insert tests. Inserts block on the one that's running."""
    number_of_threads = 22  # change this to increase the concurrency
    expected_success_runs = number_of_threads - 1
    cnx_array = []
    try:
        with conn_cnx() as cnx:
            cnx.cursor().execute(
                """