File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff 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,
You can’t perform that action at this time.
0 commit comments