Skip to content

Commit 15587d7

Browse files
authored
Improve error message (#1320)
Include message-id in errors
1 parent 777d31e commit 15587d7

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

server/svix-server/src/worker.rs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -726,7 +726,9 @@ async fn process_queue_task_inner(
726726
.find_also_related(messagecontent::Entity)
727727
.one(db)
728728
.await?
729-
.ok_or_else(|| Error::generic("Unexpected: message doesn't exist"))?;
729+
.ok_or_else(|| {
730+
Error::generic(format!("Unexpected: message doesn't exist {}", task.msg_id))
731+
})?;
730732

731733
let destination =
732734
messagedestination::Entity::secure_find_by_msg(task.msg_id.clone())
@@ -750,11 +752,13 @@ async fn process_queue_task_inner(
750752
)
751753
}
752754
QueueTask::MessageBatch(task) => {
753-
let (msg, msg_content) = message::Entity::find_by_id(task.msg_id)
755+
let (msg, msg_content) = message::Entity::find_by_id(task.msg_id.clone())
754756
.find_also_related(messagecontent::Entity)
755757
.one(db)
756758
.await?
757-
.ok_or_else(|| Error::generic("Unexpected: message doesn't exist"))?;
759+
.ok_or_else(|| {
760+
Error::generic(format!("Unexpected: message doesn't exist {}", task.msg_id))
761+
})?;
758762
(
759763
msg,
760764
msg_content,

0 commit comments

Comments
 (0)