

def watch_topic(self):
    while True:
        msgs = msgs.get_messages()
        if msgs:
            self.process_messages(msgs)

dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py Executor.watch_topic/VarMisuse@17/20 `self`->`msgs`