apunkt/plano
1
0
Fork 0
mirror of https://github.com/katanemo/plano.git synced 2026-06-17 15:25:17 +02:00
Code Issues Projects Releases Packages Wiki Activity

fix more

Browse source
This commit is contained in:
Adil Hafeez 2024-11-11 19:06:58 -08:00
parent 70fb482e2a
commit 879aeb4a60
1 changed files with 12 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

21
crates/prompt_gateway/src/http_context.rs
View file

@ -254,17 +254,20 @@ impl HttpContext for StreamContext {
}
if end_of_stream {
let start = SystemTime::now();
let since_the_epoch_ns = match start.duration_since(UNIX_EPOCH) {
Ok(duration) => duration.as_nanos(),
Err(_) => {
eprintln!("System time went backwards");
std::process::exit(1);
}
};
if let Some(traceparent) = self.traceparent.as_ref() {
let since_the_epoch_ns = match SystemTime::now().duration_since(UNIX_EPOCH) {
Ok(duration) => duration.as_nanos(),
Err(_) => {
eprintln!("System time went backwards");
std::process::exit(1);
}
};
let traceparent_tokens = traceparent.split("-").collect::<Vec<&str>>();
if traceparent_tokens.len() != 4 {
warn!("traceparent header is invalid: {}", traceparent);
return Action::Continue;
}
let parent_trace_id = traceparent_tokens[1];
let parent_span_id = traceparent_tokens[2];
let mut trace_data = common::tracing::TraceData::new();