MCPcopy Create free account
hub / github.com/QuantumNous/new-api / writeTaskPluginProtocolTimeoutResponse

Function writeTaskPluginProtocolTimeoutResponse

controller/plugin_protocol.go:1128–1140  ·  view source on GitHub ↗
(
	c *gin.Context,
	machine *relay.PluginResponsesMachine,
	lastStatus string,
)

Source from the content-addressed store, hash-verified

1126}
1127
1128func writeTaskPluginProtocolTimeoutResponse(
1129 c *gin.Context,
1130 machine *relay.PluginResponsesMachine,
1131 lastStatus string,
1132) {
1133 response, err := machine.TimeoutResponse(lastStatus)
1134 if err != nil {
1135 logger.LogError(c, "task protocol timeout response failed: "+err.Error())
1136 respondPluginProtocolError(c, http.StatusInternalServerError, "task_protocol_error", "Task protocol request failed")
1137 return
1138 }
1139 c.JSON(http.StatusOK, response)
1140}
1141
1142func taskPluginProtocolJSONValue(value any) (any, error) {
1143 encoded, err := common.Marshal(value)

Callers 1

waitTaskPluginProtocolFunction · 0.85

Calls 4

LogErrorFunction · 0.92
TimeoutResponseMethod · 0.80
ErrorMethod · 0.45

Tested by

no test coverage detected