def star_drop(cluster, logdir, cmd, *args):
    if args:
        hosts = args
    else:
        # If user didn't specify, implied drop of unauthenticated or disabled connections
        hosts = set([k for k, v in cluster.connections.items()
                 if not isinstance(v, paramiko.Transport) or not v.is_authenticated()])
        hosts.update(cluster.disabled)
        print('Dropping %d disabled/unauthenticated connections' % len(hosts))

    for host in hosts:
        host_key = cluster.locate(host)
        if host_key:
            print('Disconnecting from %r' % host_key)
            try:
                t = cluster.connections[host_key]
                cluster.disabled.discard(host_key)
                if hasattr(t, 'close'):
                    t.close()
            except Exception as e:
                print(repr(e))
            cluster.connections.pop(host_key)
        else:
            print('Host %s not connected' % host)
input: local repo path
dataset/ETHPy150Open radssh/radssh/radssh/core_plugins/add_drop.py/star_drop--crossover with--dataset/ETHPy150Open natea/django-deployer/django_deployer/utils.py/get_template_filelist