_sink").wait()          # verify code, do not copy these code to shell.py         with open(sink_path, 'r') as f:             lines = f.read()             self.assertEqual(lines, '0,hi,hello\n' + '0,hi,hello\n')