def _get_execution_state_with_watch(self, topologyName, callback, isWatching):
path = self.get_execution_state_path(topologyName)<EOL>if isWatching:<EOL><INDENT>LOG.info("<STR_LIT>" + path)<EOL><DEDENT>@self.client.DataWatch(path)<EOL>def watch_execution_state(data, stats):<EOL><INDENT>"""<STR_LIT>"""<EOL>if data:<EOL><INDENT>executionState = ExecutionState()<EOL>executionState.ParseFromString(data)<EOL>callback(executionState)<EOL><DEDENT>else:<EOL><INDENT>callback(None)<EOL><DEDENT>return isWatching<EOL><DEDENT>
Helper function to get execution state with
a callback. The future watch is placed
only if isWatching is True.