{"record":{"id":"d4a19d2bcb3adab8","repo":"temporalio/temporal","slug":"failed-to-get-last-enqueued-message-id-from-dlq","errorCode":null,"errorMessage":"failed to get last enqueued message id from DLQ: %v","messagePattern":"failed to get last enqueued message id from DLQ: (.+?)","errorType":"exception","errorClass":"Unavailable","httpStatus":null,"severity":"error","filePath":"common/persistence/sql/queue.go","lineNumber":183,"sourceCode":"\tblob *commonpb.DataBlob,\n) (int64, error) {\n\tvar lastMessageID int64\n\terr := q.txExecute(ctx, \"EnqueueMessageToDLQ\", func(tx sqlplugin.Tx) error {\n\t\tvar err error\n\t\tlastMessageID, err = tx.GetLastEnqueuedMessageIDForUpdate(ctx, q.getDLQTypeFromQueueType())\n\t\tswitch err {\n\t\tcase nil:\n\t\t\t_, err = tx.InsertIntoMessages(ctx, []sqlplugin.QueueMessageRow{\n\t\t\t\tnewQueueRow(q.getDLQTypeFromQueueType(), lastMessageID+1, blob),\n\t\t\t})\n\t\t\treturn err\n\t\tcase sql.ErrNoRows:\n\t\t\t_, err = tx.InsertIntoMessages(ctx, []sqlplugin.QueueMessageRow{\n\t\t\t\tnewQueueRow(q.getDLQTypeFromQueueType(), persistence.EmptyQueueMessageID+1, blob),\n\t\t\t})\n\t\t\treturn err\n\t\tdefault:\n\t\t\treturn fmt.Errorf(\"failed to get last enqueued message id from DLQ: %v\", err)\n\t\t}\n\t})\n\tif err != nil {\n\t\treturn persistence.EmptyQueueMessageID, serviceerror.NewUnavailable(err.Error())\n\t}\n\treturn lastMessageID + 1, nil\n}\n\nfunc (q *sqlQueue) ReadMessagesFromDLQ(\n\tctx context.Context,\n\tfirstMessageID int64,\n\tlastMessageID int64,\n\tpageSize int,\n\tpageToken []byte,\n) ([]*persistence.QueueMessage, []byte, error) {\n\tif len(pageToken) != 0 {\n\t\tlastReadMessageID, err := deserializePageToken(pageToken)\n\t\tif err != nil {","sourceCodeStart":165,"sourceCodeEnd":201,"githubUrl":"https://github.com/temporalio/temporal/blob/bde624efd13fbd3843654058db6d9c716166318b/common/persistence/sql/queue.go#L165-L201","documentation":"Error \"failed to get last enqueued message id from DLQ: %v\" thrown in temporalio/temporal.","triggerScenarios":"Thrown at common/persistence/sql/queue.go:183 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":[],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"bde624efd13fbd3843654058db6d9c716166318b","analyzedAt":"2026-09-01T07:18:39.080Z","contentChangedAt":null,"schemaVersion":2},"datasetVersion":"2026-09-08T10:18:20.063Z"}