Class peagen.tui.ws_client.TaskStreamClient
peagen.tui.ws_client.TaskStreamClient
TaskStreamClient(ws_url)
Consume gateway events from /ws/tasks.
Source code in peagen/tui/ws_client.py
14 15 16 17 18 19 20 21 | |
ws_url
instance-attribute
ws_url = ws_url
tasks
instance-attribute
tasks = {}
workers
instance-attribute
workers = {}
queues
instance-attribute
queues = {}
connected
instance-attribute
connected = False
on_event
on_event(cb)
Register cb to be awaited for every event.
Source code in peagen/tui/ws_client.py
23 24 25 | |
on_connection_change
on_connection_change(cb)
Register callback for connection status changes.
| PARAMETER | DESCRIPTION |
|---|---|
cb
|
Async callback that takes (is_connected, error_message)
TYPE:
|
Source code in peagen/tui/ws_client.py
27 28 29 30 31 32 33 | |
listen
async
listen()
Source code in peagen/tui/ws_client.py
43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 | |