(
application_id: Uuid,
vars: &HashMap<String, String>,
pl: &integration::LogEvent,
)
| 354 | } |
| 355 | |
| 356 | pub async fn log_event( |
| 357 | application_id: Uuid, |
| 358 | vars: &HashMap<String, String>, |
| 359 | pl: &integration::LogEvent, |
| 360 | ) { |
| 361 | tokio::spawn({ |
| 362 | let vars = vars.clone(); |
| 363 | let pl = pl.clone(); |
| 364 | |
| 365 | async move { |
| 366 | if let Err(err) = _log_event(application_id, &vars, &pl).await { |
| 367 | warn!(application_id = %application_id, error = %err.full(), "Log event error"); |
| 368 | } |
| 369 | } |
| 370 | }); |
| 371 | } |
| 372 | |
| 373 | async fn _log_event( |
| 374 | application_id: Uuid, |
no test coverage detected