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

Function writeTaskPluginProtocolFailure

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

Source from the content-addressed store, hash-verified

1076}
1077
1078func writeTaskPluginProtocolFailure(
1079 c *gin.Context,
1080 machine *relay.PluginResponsesMachine,
1081 taskStatus string,
1082) {
1083 failed, err := machine.FailureEvent(taskStatus)
1084 if err != nil {
1085 logger.LogError(c, "task protocol failure event failed: "+err.Error())
1086 return
1087 }
1088 _ = writeTaskPluginProtocolEvent(c, failed)
1089}
1090
1091func writeTaskPluginProtocolTimeout(
1092 c *gin.Context,

Callers 1

streamTaskPluginProtocolFunction · 0.85

Calls 4

LogErrorFunction · 0.92
FailureEventMethod · 0.80
ErrorMethod · 0.45

Tested by

no test coverage detected