creo que debo quitar los initializing de watch
async def watch(sub_id, query, send):
#await send_initializing(sub_id, send)
#await send_ready(sub_id, send)
connection = await get_connection()
feed = await query.changes(include_states=True, include_initial=True).run(connection)
while (await feed.fetch_next()):
item = await feed.next()
await handle_watch(item, sub_id, send)