use dal::{
DalContext,
WsEvent,
};
use hyper::Uri;
use telemetry::prelude::*;
pub type TaskId = ulid::Ulid;
/// Handler for any fatal error condition in an "async" SDF route (one that does
/// work on a background thread and returns the result via a WsEvent)
pub async fn handle_error(
ctx: &DalContext,
uri: Uri,
task_id: TaskId,
err: impl std::error::Error,
) {
let err_string = err.to_string();
error!("async route '{}' error: {}", uri.to_string(), err_string);
match WsEvent::async_error(ctx, task_id, err_string).await {
Ok(event) => {
if let Err(commit_err) = event.publish_immediately(ctx).await {
error!(si.error.message = ?commit_err.to_string(), "Unable to publish ws event for async error");
}
}
Err(creation_err) => {
error!(si.error.message = ?creation_err.to_string(), "Unable to create ws event for async error");
}
}
}
