(self, policy, role)
Processes one role in any mode
Processes one role in any mode
Processes one role in any mode
def process_remote_role(self, policy, role):
        """
        Processes one role in any mode
        """

        import dill

        self.connection_manager.announce_role(role)
        hosts = role.inventory().hosts()
        self.connection_manager.add_hosts(hosts)

        batch_size = role.serial()
        max_workers = UserDefaults.max_workers()

        self.compute_max_hostname_length(hosts)
        self.connection_manager.prepare_for_role(role)
        self.connect_to_all_hosts(hosts, role, max_workers)
        self.run_roles_on_all_hosts(hosts, policy, role, batch_size)
        self.connection_manager.event_loop()
        self.process_summary(hosts)
def process_remote_role ( self , policy , role ) : import dill self . connection_manager . announce_role ( role ) hosts = role . inventory ( ) . hosts ( ) self . connection_manager . add_hosts ( hosts ) batch_size = role . serial ( ) max_workers = UserDefaults . max_workers ( ) self . compute_max_hostname_length ( hosts ) self . connection_manager . prepare_for_role ( role ) self . connect_to_all_hosts ( hosts , role , max_workers ) self . run_roles_on_all_hosts ( hosts , policy , role , batch_size ) self . connection_manager . event_loop ( ) self . process_summary ( hosts )