def METHOD_NAME(self, loader_idx: int):
    if hasattr(self.node_list[0], 'parent_cluster'):
        target_address = self.node_list[0].parent_cluster.get_node().cql_ip_address
    else:
        target_address = self.node_list[0].cql_ip_address
    with self._per_loader_count_lock:
        threads_on_loader = self._per_loader_count.get(loader_idx, 0)
        threads_on_loader += 1
        self._per_loader_count[threads_on_loader] = threads_on_loader
    stress_cmd = self.stress_cmd.replace('nosqlbench', '') + f" hosts={target_address}"
    stress_cmd += ' table=nosqlbench_table_' + str(loader_idx + 1) + '_' + str(threads_on_loader)
    return stress_cmd