def get_scheduler_location(self, topologyName, callback=None):
if callback:<EOL><INDENT>self.scheduler_location_watchers[topologyName].append(callback)<EOL><DEDENT>else:<EOL><INDENT>scheduler_location_path = self.get_scheduler_location_path(topologyName)<EOL>with open(scheduler_location_path) as f:<EOL><INDENT>data = f.read()<EOL>scheduler_location = SchedulerLocation()<EOL>scheduler_location.ParseFromString(data)<EOL>return scheduler_location<EOL><DEDENT><DEDENT>
Get scheduler location