admincybers2 commited on
Commit
e00a7e9
·
verified ·
1 Parent(s): a301437

Upload folder using huggingface_hub

Browse files
Files changed (1) hide show
  1. space_worker/supabase.py +9 -1
space_worker/supabase.py CHANGED
@@ -191,6 +191,14 @@ class RealtimeConnection:
191
  continue
192
 
193
  message = json.loads(raw_message)
194
- if message.get("event") not in {"phx_reply"}:
 
 
 
 
 
 
 
 
195
  logger.info("received realtime event=%s topic=%s", message.get("event"), message.get("topic"))
196
  yield message
 
191
  continue
192
 
193
  message = json.loads(raw_message)
194
+ if message.get("event") == "phx_reply":
195
+ payload = message.get("payload") or {}
196
+ logger.info(
197
+ "received realtime reply topic=%s status=%s ref=%s",
198
+ message.get("topic"),
199
+ payload.get("status"),
200
+ message.get("ref"),
201
+ )
202
+ else:
203
  logger.info("received realtime event=%s topic=%s", message.get("event"), message.get("topic"))
204
  yield message