Function wait_for_logs_message_at 

pub async fn wait_for_logs_message_at(
    pool: &Pool,
    target_aih: &str,
) -> Result<(), Error>

Block until the next objectiveai.messages INSERT whose agent_instance_hierarchy payload equals target_aih. Mismatching notifications are silently consumed.