Use RunnerResponse http client method

harness · Aug 15, 2024 · c9061e2 · c9061e2
1 parent 4133030
commit c9061e2
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 1 deletion.
diff --git a/go.mod b/go.mod
@@ -36,7 +36,7 @@ require (
 	github.com/harness/godotenv/v2 v2.0.0
 	github.com/harness/godotenv/v3 v3.0.0
 	github.com/shirou/gopsutil/v3 v3.23.5
-	github.com/wings-software/dlite v1.0.0-rc.10.0.20240814162216-f8ba0cbef767
+	github.com/wings-software/dlite v1.0.0-rc.10.0.20240815144723-959a84361749
 	golang.org/x/net v0.17.0
 )
 

diff --git a/go.sum b/go.sum
@@ -178,6 +178,8 @@ github.com/wings-software/dlite v1.0.0-rc.10.0.20240809113220-0e1170e3f3e6 h1:Ko
 github.com/wings-software/dlite v1.0.0-rc.10.0.20240809113220-0e1170e3f3e6/go.mod h1:zZd6iaMk8Av1QSABGuDWdxBFO82MxE0r6PRoDsLDvCE=
 github.com/wings-software/dlite v1.0.0-rc.10.0.20240814162216-f8ba0cbef767 h1:qPsR/5fV6eL5kH1V8ltUYO4wJxrP0p/e0QNjnLgtkKM=
 github.com/wings-software/dlite v1.0.0-rc.10.0.20240814162216-f8ba0cbef767/go.mod h1:zZd6iaMk8Av1QSABGuDWdxBFO82MxE0r6PRoDsLDvCE=
+github.com/wings-software/dlite v1.0.0-rc.10.0.20240815144723-959a84361749 h1:dPNucBCqbHbSUTVBDy1O+4J8oCZ5SdgflFqnZKEN1VM=
+github.com/wings-software/dlite v1.0.0-rc.10.0.20240815144723-959a84361749/go.mod h1:zZd6iaMk8Av1QSABGuDWdxBFO82MxE0r6PRoDsLDvCE=
 github.com/xi2/xz v0.0.0-20171230120015-48954b6210f8 h1:nIPpBwaJSVYIxUFsDv3M8ofmx9yWTog9BfvIu0q41lo=
 github.com/xi2/xz v0.0.0-20171230120015-48954b6210f8/go.mod h1:HUYIGzjTL3rfEspMxjDjgmT5uz5wzYJKVo23qUhYTos=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

diff --git a/pipeline/runtime/step_executor.go b/pipeline/runtime/step_executor.go
@@ -407,6 +407,7 @@ func (e *StepExecutor) sendStepStatus(r *api.StartStepRequest, response *api.VMT
 
 func (e *StepExecutor) sendStatus(r *api.StartStepRequest, delegateClient *delegate.HTTPClient, response *api.VMTaskExecutionResponse) error {
 	if r.StepStatus.RunnerResponse {
+		logrus.WithField("id", r.ID).Infoln("Sending runner step status")
 		status := client.Success
 		if response.CommandExecutionStatus == api.Failure {
 			status = client.Failure
@@ -430,6 +431,7 @@ func (e *StepExecutor) sendStatus(r *api.StartStepRequest, delegateClient *deleg
 		}
 		return delegateClient.SendRunnerStatus(context.Background(), r.StepStatus.DelegateID, r.StepStatus.TaskID, taskResponse)
 	} else {
+		logrus.WithField("id", r.ID).Infoln("Sending legacy step status")
 		// For legacy backwards compatibility treat timeout as failure
 		if response.CommandExecutionStatus == api.Timeout {
 			response.CommandExecutionStatus = api.Failure