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