fix: sync program status updates
This commit is contained in:
1 parent
ed62d42a63
commit
38bcbfc697
4 files changed
+40
-5
No files matched your search
@@ -205,6 +205,7 @@ async def catalog_events(request: Request, db: AsyncSession = Depends(get_db)):
|
||||
async def events():
|
||||
previous = None
|
||||
while not await request.is_disconnected():
|
||||
db.expire_all()
|
||||
streams = await StreamService(db).get_public_streams()
|
||||
payload = json.dumps(
|
||||
[_serialize(stream, include_private=False) for stream in streams],
|
||||
|
||||
Reference in new issue
Block a user