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

Function writeTaskPluginProtocolTimeout

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

Source from the content-addressed store, hash-verified

1089}
1090
1091func writeTaskPluginProtocolTimeout(
1092 c *gin.Context,
1093 machine *relay.PluginResponsesMachine,
1094 taskStatus string,
1095) {
1096 incomplete, err := machine.TimeoutEvent(taskStatus)
1097 if err != nil {
1098 logger.LogError(c, "task protocol timeout event failed: "+err.Error())
1099 return
1100 }
1101 _ = writeTaskPluginProtocolEvent(c, incomplete)
1102}
1103
1104func writeTaskPluginProtocolFailureResponse(
1105 c *gin.Context,

Callers 1

streamTaskPluginProtocolFunction · 0.85

Calls 4

LogErrorFunction · 0.92
TimeoutEventMethod · 0.80
ErrorMethod · 0.45

Tested by

no test coverage detected