{"record":{"id":"1bcf48c139d556a3","repo":"temporalio/temporal","slug":"rowsaffected-returned-error-when-initializing-queu","errorCode":null,"errorMessage":"rowsAffected returned error when initializing queue metadata  %v: %v","messagePattern":"rowsAffected returned error when initializing queue metadata  (.+?): (.+?)","errorType":"exception","errorClass":"Unavailable","httpStatus":null,"severity":"error","filePath":"common/persistence/sql/queue.go","lineNumber":336,"sourceCode":") error {\n\t_, err := q.DB.SelectFromQueueMetadata(ctx, sqlplugin.QueueMetadataFilter{\n\t\tQueueType: q.queueType,\n\t})\n\tswitch err {\n\tcase nil:\n\t\treturn nil\n\tcase sql.ErrNoRows:\n\t\tresult, err := q.DB.InsertIntoQueueMetadata(ctx, &sqlplugin.QueueMetadataRow{\n\t\t\tQueueType:    q.queueType,\n\t\t\tData:         blob.Data,\n\t\t\tDataEncoding: blob.EncodingType.String(),\n\t\t})\n\t\tif err != nil {\n\t\t\treturn serviceerror.NewUnavailablef(\"initializeQueueMetadata 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 when initializing queue metadata  %v: %v\", q.queueType, err)\n\t\t}\n\t\tif rowsAffected != 1 {\n\t\t\treturn fmt.Errorf(\"rowsAffected returned %v queue metadata instead of one\", rowsAffected)\n\t\t}\n\t\treturn nil\n\tdefault:\n\t\treturn err\n\t}\n}\n\nfunc (q *sqlQueue) initializeDLQMetadata(\n\tctx context.Context,\n\tblob *commonpb.DataBlob,\n) error {\n\t_, err := q.DB.SelectFromQueueMetadata(ctx, sqlplugin.QueueMetadataFilter{\n\t\tQueueType: q.getDLQTypeFromQueueType(),\n\t})\n\tswitch err {","sourceCodeStart":318,"sourceCodeEnd":354,"githubUrl":"https://github.com/temporalio/temporal/blob/bde624efd13fbd3843654058db6d9c716166318b/common/persistence/sql/queue.go#L318-L354","documentation":"Error \"rowsAffected returned error when initializing queue metadata  %v: %v\" thrown in temporalio/temporal.","triggerScenarios":"Thrown at common/persistence/sql/queue.go:336 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"}