{"record":{"id":"45babbfea14489f9","repo":"temporalio/temporal","slug":"rowsaffected-returned-error-for-dlq-metadata-v","errorCode":null,"errorMessage":"rowsAffected returned error for DLQ metadata %v: %v","messagePattern":"rowsAffected returned error for DLQ metadata (.+?): (.+?)","errorType":"exception","errorClass":"Unavailable","httpStatus":null,"severity":"error","filePath":"common/persistence/sql/queue.go","lineNumber":281,"sourceCode":"}\n\nfunc (q *sqlQueue) UpdateDLQAckLevel(\n\tctx context.Context,\n\tmetadata *persistence.InternalQueueMetadata,\n) error {\n\terr := q.txExecute(ctx, \"UpdateDLQAckLevel\", func(tx sqlplugin.Tx) error {\n\n\t\tresult, err := tx.UpdateQueueMetadata(ctx, &sqlplugin.QueueMetadataRow{\n\t\t\tQueueType:    q.getDLQTypeFromQueueType(),\n\t\t\tData:         metadata.Blob.Data,\n\t\t\tDataEncoding: metadata.Blob.EncodingType.String(),\n\t\t})\n\t\tif err != nil {\n\t\t\treturn serviceerror.NewUnavailablef(\"UpdateDLQAckLevel operation failed. Error %v\", err)\n\t\t}\n\t\trowsAffected, err := result.RowsAffected()\n\t\tif err != nil {\n\t\t\treturn fmt.Errorf(\"rowsAffected returned error for DLQ metadata %v: %v\", q.queueType, err)\n\t\t}\n\t\tif rowsAffected != 1 {\n\t\t\treturn fmt.Errorf(\"rowsAffected returned %v DLQ metadata instead of one\", rowsAffected)\n\t\t}\n\t\treturn nil\n\t})\n\n\tif err != nil {\n\t\treturn serviceerror.NewUnavailable(err.Error())\n\t}\n\treturn nil\n}\n\nfunc (q *sqlQueue) GetDLQAckLevels(\n\tctx context.Context,\n) (*persistence.InternalQueueMetadata, error) {\n\trow, err := q.DB.SelectFromQueueMetadata(ctx, sqlplugin.QueueMetadataFilter{\n\t\tQueueType: q.getDLQTypeFromQueueType(),","sourceCodeStart":263,"sourceCodeEnd":299,"githubUrl":"https://github.com/temporalio/temporal/blob/bde624efd13fbd3843654058db6d9c716166318b/common/persistence/sql/queue.go#L263-L299","documentation":"Error \"rowsAffected returned error for DLQ metadata %v: %v\" thrown in temporalio/temporal.","triggerScenarios":"Thrown at common/persistence/sql/queue.go:281 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"}