mirror of
https://github.com/huggingface/candle.git
synced 2025-06-16 02:38:10 +00:00
Cuda fix for starcoder. (#266)
* Cuda fix for starcoder. * Nicer output.
This commit is contained in:
@ -38,7 +38,10 @@ impl TextGeneration {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn run(&mut self, prompt: &str, sample_len: usize) -> Result<()> {
|
fn run(&mut self, prompt: &str, sample_len: usize) -> Result<()> {
|
||||||
|
use std::io::Write;
|
||||||
println!("starting the inference loop");
|
println!("starting the inference loop");
|
||||||
|
print!("{prompt}");
|
||||||
|
std::io::stdout().flush()?;
|
||||||
let mut tokens = self
|
let mut tokens = self
|
||||||
.tokenizer
|
.tokenizer
|
||||||
.encode(prompt, true)
|
.encode(prompt, true)
|
||||||
@ -49,7 +52,6 @@ impl TextGeneration {
|
|||||||
let mut new_tokens = vec![];
|
let mut new_tokens = vec![];
|
||||||
let start_gen = std::time::Instant::now();
|
let start_gen = std::time::Instant::now();
|
||||||
for index in 0..sample_len {
|
for index in 0..sample_len {
|
||||||
let start_gen = std::time::Instant::now();
|
|
||||||
let (context_size, past_len) = if self.model.config().use_cache && index > 0 {
|
let (context_size, past_len) = if self.model.config().use_cache && index > 0 {
|
||||||
(1, tokens.len().saturating_sub(1))
|
(1, tokens.len().saturating_sub(1))
|
||||||
} else {
|
} else {
|
||||||
@ -63,21 +65,17 @@ impl TextGeneration {
|
|||||||
let next_token = self.logits_processor.sample(&logits)?;
|
let next_token = self.logits_processor.sample(&logits)?;
|
||||||
tokens.push(next_token);
|
tokens.push(next_token);
|
||||||
new_tokens.push(next_token);
|
new_tokens.push(next_token);
|
||||||
println!("> {:?}", start_gen.elapsed());
|
let token = self
|
||||||
println!(
|
.tokenizer
|
||||||
"{} token: {} '{}'",
|
.decode(vec![next_token], true)
|
||||||
index + 1,
|
.map_err(E::msg)?;
|
||||||
next_token,
|
print!("{token}");
|
||||||
self.tokenizer
|
std::io::stdout().flush()?;
|
||||||
.decode(vec![next_token], true)
|
|
||||||
.map_err(E::msg)?
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
let dt = start_gen.elapsed();
|
let dt = start_gen.elapsed();
|
||||||
println!(
|
println!(
|
||||||
"{sample_len} tokens generated ({} token/s)\n----\n{}\n----",
|
"{sample_len} tokens generated ({:.3} token/s)",
|
||||||
sample_len as f64 / dt.as_secs_f64(),
|
sample_len as f64 / dt.as_secs_f64(),
|
||||||
self.tokenizer.decode(new_tokens, true).map_err(E::msg)?
|
|
||||||
);
|
);
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
@ -22,11 +22,11 @@ fn layer_norm(size: usize, eps: f64, vb: VarBuilder) -> Result<LayerNorm> {
|
|||||||
Ok(LayerNorm::new(weight, bias, eps))
|
Ok(LayerNorm::new(weight, bias, eps))
|
||||||
}
|
}
|
||||||
|
|
||||||
fn make_causal_mask(t: usize) -> Result<Tensor> {
|
fn make_causal_mask(t: usize, device: &Device) -> Result<Tensor> {
|
||||||
let mask: Vec<_> = (0..t)
|
let mask: Vec<_> = (0..t)
|
||||||
.flat_map(|i| (0..t).map(move |j| u32::from(j <= i)))
|
.flat_map(|i| (0..t).map(move |j| u32::from(j <= i)))
|
||||||
.collect();
|
.collect();
|
||||||
let mask = Tensor::from_slice(&mask, (t, t), &Device::Cpu)?;
|
let mask = Tensor::from_slice(&mask, (t, t), device)?;
|
||||||
Ok(mask)
|
Ok(mask)
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -327,7 +327,7 @@ impl GPTBigCode {
|
|||||||
.collect::<Result<Vec<_>>>()?;
|
.collect::<Result<Vec<_>>>()?;
|
||||||
let ln_f = layer_norm(hidden_size, cfg.layer_norm_epsilon, vb_t.pp("ln_f"))?;
|
let ln_f = layer_norm(hidden_size, cfg.layer_norm_epsilon, vb_t.pp("ln_f"))?;
|
||||||
let lm_head = linear(hidden_size, cfg.vocab_size, false, vb.pp("lm_head"))?;
|
let lm_head = linear(hidden_size, cfg.vocab_size, false, vb.pp("lm_head"))?;
|
||||||
let bias = make_causal_mask(cfg.max_position_embeddings)?;
|
let bias = make_causal_mask(cfg.max_position_embeddings, vb.device())?;
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
wte,
|
wte,
|
||||||
wpe,
|
wpe,
|
||||||
|
Reference in New Issue
Block a user