diff --git a/coprocess_test.go b/coprocess_test.go
index 9ea4daba50c..50ee06d65b3 100644
--- a/coprocess_test.go
+++ b/coprocess_test.go
@@ -250,6 +250,22 @@ func TestCoProcessReturnOverrides(t *testing.T) {
 	}
 }
 
+func TestCoProcessReturnOverridesErrorMessage(t *testing.T) {
+	spec := createSpecTest(t, basicCoProcessDef)
+	chain := buildCoProcessChain(spec, "hook_test_return_overrides_error", coprocess.HookType_Pre, apidef.MiddlewareDriver("python"))
+	session := createNonThrottledSession()
+	spec.SessionManager.UpdateSession("abc", session, 60)
+
+	recorder := httptest.NewRecorder()
+
+	req := testReq(t, "GET", "/headers", nil)
+	req.Header.Set("authorization", "abc")
+	chain.ServeHTTP(recorder, req)
+	if recorder.Code != 401 || recorder.Body.String() != "custom error message" {
+		t.Fatal("ReturnOverrides HTTP response is invalid")
+	}
+}
+
 const basicCoProcessDef = `{
 	"api_id": "1",
 	"org_id": "default",
diff --git a/coprocess_test_helpers.go b/coprocess_test_helpers.go
index 3473808d844..daf26fbbbc3 100644
--- a/coprocess_test_helpers.go
+++ b/coprocess_test_helpers.go
@@ -159,6 +159,11 @@ func applyTestHooks(objectPtr unsafe.Pointer) {
 			ResponseCode:  200,
 			ResponseError: "body",
 		}
+	case "hook_test_return_overrides_error":
+		object.Request.ReturnOverrides = &coprocess.ReturnOverrides{
+			ResponseCode:  401,
+			ResponseError: "custom error message",
+		}
 	case "hook_test_bad_auth_using_id_extractor":
 	case "hook_test_bad_auth_cp_error":
 	case "hook_test_successful_auth":