We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2efb0cc commit a38739fCopy full SHA for a38739f
1 file changed
rootfs/api/consumers.py
@@ -96,11 +96,11 @@ async def send(self, data):
96
async def task(self):
97
deadline = time.time() + settings.DRYCC_APP_POD_EXEC_TIMEOUT
98
while self.stream.is_open() and self.conneted and time.time() < deadline:
99
- self.stream.update(timeout=9)
100
- if await sync_to_async(self.stream.peek_stdout)():
+ await sync_to_async(self.stream.update)(0.1)
+ if self.stream.peek_stdout():
101
data = self.stream.read_stdout()
102
- elif await sync_to_async(self.stream.peek_stderr)():
103
- data = self.stream.peek_stderr()
+ elif self.stream.peek_stderr():
+ data = self.stream.read_stderr()
104
else:
105
data = None
106
await self.send(data)
0 commit comments