def run(connection):
volumes = volume_manager.get_watched_volumes(connection)<EOL>for volume in volumes:<EOL><INDENT>_ensure_snapshot(connection, volume)<EOL>_remove_old_snapshots(connection, volume)<EOL><DEDENT>
Ensure that we have snapshots for a given volume

    :type connection: boto.ec2.connection.EC2Connection
    :param connection: EC2 connection object
    :returns: None