diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-06-26 12:26:11 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-17 12:54:39 -0700 |
| commit | cd9aa73c8463fa0214d6ee6109c63396e623dbaa (patch) | |
| tree | 0f74f860f4a58987f2fe4bb7eeabf6cede169329 /test | |
| parent | d179a3f62e7d225b087290b51f3bc387aa9d434b (diff) | |
| download | kafka-python-cd9aa73c8463fa0214d6ee6109c63396e623dbaa.tar.gz | |
Catch select errors while capturing test fixture logs
Diffstat (limited to 'test')
| -rw-r--r-- | test/service.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/test/service.py b/test/service.py index 55cc739..8895a10 100644 --- a/test/service.py +++ b/test/service.py @@ -72,7 +72,13 @@ class SpawnedService(threading.Thread): def run(self): self._spawn() while True: - (rds, _, _) = select.select([self.child.stdout, self.child.stderr], [], [], 1) + try: + (rds, _, _) = select.select([self.child.stdout, self.child.stderr], [], [], 1) + except select.error as ex: + if ex.args[0] == 4: + continue + else: + raise if self.child.stdout in rds: line = self.child.stdout.readline() |