def rsync_snapshots(machine_name, simulation_directory_from='', simulation_directory_to='.', snapshot_indices=snapshot_indices_keep):
    "\n    Use rsync to copy snapshot file[s].\n\n    Parameters\n    ----------\n    machine_name : str : 'pfe', 'stampede', 'bw', 'peloton'\n    directory_from : str : directory to copy from\n    directory_to : str : local directory to put snapshots\n    snapshot_indices : int or list : index[s] of snapshots to transfer\n    "
    snapshot_name_base = 'snap*_{:03d}*'
    directory_from = (ut.io.get_path(simulation_directory_from) + 'output/')
    directory_to = (ut.io.get_path(simulation_directory_to) + 'output/.')
    if np.isscalar(snapshot_indices):
        snapshot_indices = [snapshot_indices]
    snapshot_path_names = ''
    for snapshot_index in snapshot_indices:
        snapshot_path_names += ((directory_from + snapshot_name_base.format(snapshot_index)) + ' ')
    command = 'rsync -ahvP --size-only '
    command += '{}:"{}" {}'.format(machine_name, snapshot_path_names, directory_to)
    print('\n* executing:\n{}\n'.format(command))
    os.system(command)
Use rsync to copy snapshot file[s].

Parameters
----------
machine_name : str : 'pfe', 'stampede', 'bw', 'peloton'
directory_from : str : directory to copy from
directory_to : str : local directory to put snapshots
snapshot_indices : int or list : index[s] of snapshots to transfer
def rsync_snapshots(machine_name, simulation_directory_from=, simulation_directory_to='.', snapshot_indices=snapshot_indices_keep):
    "\n    Use rsync to copy snapshot file[s].\n\n    Parameters\n    ----------\n    machine_name : str : 'pfe', 'stampede', 'bw', 'peloton'\n    directory_from : str : directory to copy from\n    directory_to : str : local directory to put snapshots\n    snapshot_indices : int or list : index[s] of snapshots to transfer\n    "
    snapshot_name_base = 'snap*_{:03d}*'
    directory_from = (ut.io.get_path(simulation_directory_from) + 'output/')
    directory_to = (ut.io.get_path(simulation_directory_to) + 'output/.')
    if np.isscalar(snapshot_indices):
        snapshot_indices = [snapshot_indices]
    snapshot_path_names = 
    for snapshot_index in snapshot_indices:
        snapshot_path_names += ((directory_from + snapshot_name_base.format(snapshot_index)) + ' ')
    command = 'rsync -ahvP --size-only '
    command += '{}:"{}" {}'.format(machine_name, snapshot_path_names, directory_to)
    print('\n* executing:\n{}\n'.format(command))
    os.system(command)