diff --git a/airlock_libs/src/services.rs b/airlock_libs/src/services.rs index e4dc9fc..ff51043 100644 --- a/airlock_libs/src/services.rs +++ b/airlock_libs/src/services.rs @@ -1,7 +1,6 @@ -use opentelemetry::trace::SpanContext; - use crate::modules::datatypes::*; use crate::prelude::*; +use opentelemetry::trace::SpanContext; #[pyfunction] pub fn pull_policy_exec_histories( @@ -111,7 +110,7 @@ pub fn pull_policy_exec_histories( let (tx, rx) = unbounded::<(SpanContext, Vec)>(); let pb_clone = progress_bar.clone(); thread::spawn(move || { - let tracer = global::tracer("Loxide"); + let tracer = global::tracer("loxide"); let mut seen: HashMap<(String, String, String), Group> = if writeable_filepath.exists() { let contents: String = fs::read_to_string(&writeable_filepath).unwrap_or_default(); @@ -292,7 +291,6 @@ pub fn pull_policy_exec_histories( } } } - tracer_provider.force_flush(); }); progress_bar .lock() @@ -305,7 +303,6 @@ pub fn pull_policy_exec_histories( std::process::abort(); } }; - tracer_provider.force_flush(); tracer_provider .shutdown() .expect("Failed to Shutdown Tracer Provdier"); @@ -346,7 +343,7 @@ async fn history_logging( ); let res: Result = client .post(format!("{}/v1/logging/exechistories", base_url)) - .json(&payload) + .body(payload) .send() .await; match res {