def is_leader(deployment, service_name):
    for unit_name, sentry in deployment.sentry.get(service_name, {}).items():
        output, exit_code = sentry.run('is-leader')
        if exit_code == 0:
            return sentry
    return None