mirror of
https://github.com/zenlm/engine.git
synced 2026-10-30 15:00:05 +00:00
* Add a python example * Add some more rust and server examples * rm * Clarify
60 lines
1.8 KiB
Rust
60 lines
1.8 KiB
Rust
use anyhow::Result;
|
|
use mistralrs::{
|
|
AutoDeviceMapParams, DeviceMapSetting, IsqType, PagedAttentionMetaBuilder, RequestBuilder,
|
|
TextMessageRole, TextMessages, TextModelBuilder,
|
|
};
|
|
|
|
#[tokio::main]
|
|
async fn main() -> Result<()> {
|
|
let auto_map_params = AutoDeviceMapParams::Text {
|
|
max_seq_len: 4096,
|
|
max_batch_size: 2,
|
|
};
|
|
let model = TextModelBuilder::new("meta-llama/Llama-3.3-70B-Instruct")
|
|
.with_isq(IsqType::Q8_0)
|
|
.with_logging()
|
|
.with_paged_attn(|| PagedAttentionMetaBuilder::default().build())?
|
|
.with_device_mapping(DeviceMapSetting::Auto(auto_map_params))
|
|
.build()
|
|
.await?;
|
|
|
|
let messages = TextMessages::new()
|
|
.add_message(
|
|
TextMessageRole::System,
|
|
"You are an AI agent with a specialty in programming.",
|
|
)
|
|
.add_message(
|
|
TextMessageRole::User,
|
|
"Hello! How are you? Please write generic binary search function in Rust.",
|
|
);
|
|
|
|
let response = model.send_chat_request(messages).await?;
|
|
|
|
println!("{}", response.choices[0].message.content.as_ref().unwrap());
|
|
dbg!(
|
|
response.usage.avg_prompt_tok_per_sec,
|
|
response.usage.avg_compl_tok_per_sec
|
|
);
|
|
|
|
// Next example: Return some logprobs with the `RequestBuilder`, which enables higher configurability.
|
|
let request = RequestBuilder::new().return_logprobs(true).add_message(
|
|
TextMessageRole::User,
|
|
"Please write a mathematical equation where a few numbers are added.",
|
|
);
|
|
|
|
let response = model.send_chat_request(request).await?;
|
|
|
|
println!(
|
|
"Logprobs: {:?}",
|
|
&response.choices[0]
|
|
.logprobs
|
|
.as_ref()
|
|
.unwrap()
|
|
.content
|
|
.as_ref()
|
|
.unwrap()[0..3]
|
|
);
|
|
|
|
Ok(())
|
|
}
|