subst_dict.update({'ID': '{}{}'.format(subst_dict['ID_PREFIX'], prefix_list[i])})
url = url_templ.substitute({'HOST': host})
data = data_templ.substitute(subst_dict)
- timeout = int(subst_dict['DURATION'])+60
+ timeout = int(subst_dict['DURATION'])+150
logger.info('url: {}, data: {}, timeout: {}'.format(url, data, timeout))
t = threading.Thread(target=_send_http_request_thread_impl,
args=(resqueue, url, data, timeout))
def start_produce_transactions_on_nodes(host_list, prefix_list, id_prefix,
- duration, rate, isolated_transactions_flag=True, reset_globals=True):
+ duration, rate, isolated_transactions_flag=False, reset_globals=True):
"""Invoke produce-transactions rpcs on given nodes.
:param host_list: list of ip address of odl nodes