diff --git a/lib/dal/src/attribute/value.rs b/lib/dal/src/attribute/value.rs index 1de443f021..ed3ea8af2f 100644 --- a/lib/dal/src/attribute/value.rs +++ b/lib/dal/src/attribute/value.rs @@ -414,6 +414,13 @@ impl AttributeValue { Ok(av) } + #[instrument( + name = "attribute_value.update", + level = "info", + skip_all, + fields( + attribute_value.id = ?attribute_value_id + ))] pub async fn update( ctx: &DalContext, attribute_value_id: AttributeValueId, @@ -1885,6 +1892,13 @@ impl AttributeValue { Ok(()) } + #[instrument( + name = "attribute_value.set_value", + level = "info", + skip_all, + fields( + attribute_value.id = ?attribute_value_id + ))] pub async fn set_value( ctx: &DalContext, attribute_value_id: AttributeValueId, @@ -1960,15 +1974,18 @@ impl AttributeValue { } None => serde_json::Value::Null, }; + let total_start = std::time::Instant::now(); let result_channel = FuncRunner::run_attribute_value(ctx, attribute_value_id, func_id, func_args) .await .map_err(Box::new)?; + info!("Getting channel took: {:?}", total_start.elapsed()); let func_values = result_channel .await .map_err(|_| AttributeValueError::FuncRunnerSend)? .map_err(Box::new)?; + info!("Waiting for values took: {:?}", total_start.elapsed()); Self::set_real_values(ctx, attribute_value_id, func_values).await?; Ok(()) diff --git a/lib/dal/src/component.rs b/lib/dal/src/component.rs index 92b619b67a..43c246b05f 100644 --- a/lib/dal/src/component.rs +++ b/lib/dal/src/component.rs @@ -414,6 +414,13 @@ impl Component { result: ComponentResult, ); + #[instrument( + name = "component.new", + level = "info", + skip_all, + fields( + schema_variant.id = ?schema_variant_id + ))] pub async fn new( ctx: &DalContext, name: impl Into, diff --git a/lib/dal/src/func/runner.rs b/lib/dal/src/func/runner.rs index 1fc59beffe..a53937c4c0 100644 --- a/lib/dal/src/func/runner.rs +++ b/lib/dal/src/func/runner.rs @@ -638,7 +638,7 @@ impl FuncRunner { #[instrument( name = "func_runner.run_attribute_value", - level = "debug", + level = "info", skip_all, fields( job.id = Empty, @@ -672,7 +672,7 @@ impl FuncRunner { // and in order to time the function's preparation vs. execution timings. #[instrument( name = "func_runner.run_attribute_value.prepare", - level = "debug", + level = "info", skip_all, fields() )]