def streaming_init(self):
        """
        Send out initialization variables and process init from modules

        Returns
        -------
        None
        """
        system = self.system
        config = self.config
        if system.config.dime_enable:
            config.compute_flows = True
            system.streaming.send_init(recepient='all')
            logger.info('Waiting for modules to send init info...')
            sleep(0.5)
            system.streaming.sync_and_handle()
def streaming_init ( self ) : system = self . system config = self . config if system . config . dime_enable : config . compute_flows = True system . streaming . send_init ( recepient = 'all' ) logger . info ( 'Waiting for modules to send init info...' ) sleep ( 0.5 ) system . streaming . sync_and_handle ( )
Send out initialization variables and process init from modules

        Returns
        -------
        None