|
|
@ -179,7 +179,7 @@ async def main():
|
|
|
|
next_update = datetime.now() + timedelta(minutes=15)
|
|
|
|
next_update = datetime.now() + timedelta(minutes=15)
|
|
|
|
|
|
|
|
|
|
|
|
for mxid in next_batch:
|
|
|
|
for mxid in next_batch:
|
|
|
|
sync = await matrix[mxid].sync(timeout=30000,
|
|
|
|
sync = await matrix[mxid].sync(timeout=10000,
|
|
|
|
sync_filter=sync_filter,
|
|
|
|
sync_filter=sync_filter,
|
|
|
|
since=next_batch[mxid])
|
|
|
|
since=next_batch[mxid])
|
|
|
|
next_batch[mxid] = sync.next_batch
|
|
|
|
next_batch[mxid] = sync.next_batch
|
|
|
|