{"record":{"id":"7c21146b2ba29f8c","repo":"temporalio/temporal","slug":"failed-to-get-last-enqueued-message-id-v","errorCode":null,"errorMessage":"failed to get last enqueued message id: %v","messagePattern":"failed to get last enqueued message id: (.+?)","errorType":"exception","errorClass":"Unavailable","httpStatus":null,"severity":"error","filePath":"common/persistence/sql/queue.go","lineNumber":66,"sourceCode":"func (q *sqlQueue) EnqueueMessage(\n\tctx context.Context,\n\tblob *commonpb.DataBlob,\n) error {\n\terr := q.txExecute(ctx, \"EnqueueMessage\", func(tx sqlplugin.Tx) error {\n\t\tlastMessageID, err := tx.GetLastEnqueuedMessageIDForUpdate(ctx, q.queueType)\n\t\tswitch err {\n\t\tcase nil:\n\t\t\t_, err = tx.InsertIntoMessages(ctx, []sqlplugin.QueueMessageRow{\n\t\t\t\tnewQueueRow(q.queueType, 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.queueType, 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: %v\", err)\n\t\t}\n\t})\n\tif err != nil {\n\t\treturn serviceerror.NewUnavailable(err.Error())\n\t}\n\treturn nil\n}\n\nfunc (q *sqlQueue) ReadMessages(\n\tctx context.Context,\n\tlastMessageID int64,\n\tpageSize int,\n) ([]*persistence.QueueMessage, error) {\n\trows, err := q.DB.RangeSelectFromMessages(ctx, sqlplugin.QueueMessagesRangeFilter{\n\t\tQueueType:    q.queueType,\n\t\tMinMessageID: lastMessageID,\n\t\tMaxMessageID: persistence.MaxQueueMessageID,\n\t\tPageSize:     pageSize,","sourceCodeStart":48,"sourceCodeEnd":84,"githubUrl":"https://github.com/temporalio/temporal/blob/bde624efd13fbd3843654058db6d9c716166318b/common/persistence/sql/queue.go#L48-L84","documentation":"Error \"failed to get last enqueued message id: %v\" thrown in temporalio/temporal.","triggerScenarios":"Thrown at common/persistence/sql/queue.go:66 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"}