( c *gin.Context, machine *relay.PluginResponsesMachine, taskStatus string, )
| 1076 | } |
| 1077 | |
| 1078 | func 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 | |
| 1091 | func writeTaskPluginProtocolTimeout( |
| 1092 | c *gin.Context, |
no test coverage detected