def execute(self, program, start=None, stop=None, resolution=None,
                max_delay=None, persistent=False, immediate=False,
                disable_all_metric_publishes=None):
        """Execute the given SignalFlow program and stream the output back."""
        params = self._get_params(start=start, stop=stop,
                                  resolution=resolution,
                                  maxDelay=max_delay,
                                  persistent=persistent,
                                  immediate=immediate,
                                  disableAllMetricPublishes=disable_all_metric_publishes)

        def exec_fn(since=None):
            if since:
                params['start'] = since
            return self._transport.execute(program, params)

        c = computation.Computation(exec_fn)
        self._computations.add(c)
        return c
def execute ( self , program , start = None , stop = None , resolution = None , max_delay = None , persistent = False , immediate = False , disable_all_metric_publishes = None ) : params = self . _get_params ( start = start , stop = stop , resolution = resolution , maxDelay = max_delay , persistent = persistent , immediate = immediate , disableAllMetricPublishes = disable_all_metric_publishes ) def exec_fn ( since = None ) : if since : params [ 'start' ] = since return self . _transport . execute ( program , params ) c = computation . Computation ( exec_fn ) self . _computations . add ( c ) return c
Execute the given SignalFlow program and stream the output back.