Skip to content

Commit e381bee

Browse files
committed
chore(controller): add channel for pod exec
1 parent 2edcaff commit e381bee

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

rootfs/api/consumers.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,7 @@ async def receive(self, text_data=None, bytes_data=None):
125125
await self.close(code=1000)
126126
elif self.stream is not None:
127127
data = text_data if text_data else bytes_data
128-
await sync_to_async(self.stream.write_stdin)(data)
128+
channel, data = ord(data[0]), data[1:]
129+
await sync_to_async(self.stream.write_channel)(channel, data)
129130
else:
130131
raise ValueError("This operation is not supported!")

0 commit comments

Comments
 (0)