awaken-runtime 0.6.0

Phase-based execution engine, plugin system, and agent loop for Awaken
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

use std::sync::atomic::{AtomicU64, Ordering};

use awaken_runtime_contract::contract::executor::InferenceRequest;

static LOGICAL_INFERENCE_SEQ: AtomicU64 = AtomicU64::new(1);

pub(super) fn ensure_logical_inference_id(request: &mut InferenceRequest) {
    let routing_key = request.routing_key.get_or_insert_with(Default::default);
    if routing_key.logical_inference_id.is_none() {
        let id = LOGICAL_INFERENCE_SEQ.fetch_add(1, Ordering::Relaxed);
        routing_key.logical_inference_id = Some(format!("stream-{id}"));
    }
}