def get_execution_state(self, topologyName, callback=None):
if callback:<EOL><INDENT>self.execution_state_watchers[topologyName].append(callback)<EOL><DEDENT>else:<EOL><INDENT>execution_state_path = self.get_execution_state_path(topologyName)<EOL>with open(execution_state_path) as f:<EOL><INDENT>data = f.read()<EOL>executionState = ExecutionState()<EOL>executionState.ParseFromString(data)<EOL>return executionState<EOL><DEDENT><DEDENT>
Get execution state