Skip to content

Commit 6d33547

Browse files
author
Arta Asadi
committed
fix: add more logs to task result
1 parent 38067d7 commit 6d33547

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

discovery/pkg/task/run-task.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,10 @@ func (tr *TaskRunner) describeIntegrationResourceTypes(ctx context.Context, i In
212212
return marshalErr
213213
}
214214
msgId := fmt.Sprintf("task-run-result-%d-%d", tr.request.TaskDefinition.RunID, time.Now().Unix())
215+
tr.logger.Info("Publishing intermediate progress",
216+
zap.String("msgId", msgId),
217+
zap.Int("resultSize", len(responseJson)), // Log size
218+
zap.String("status", string(tr.response.Status)))
215219
if _, err = tr.jq.Produce(ctx, envs.ResultTopicName, responseJson, msgId); err != nil { // Use original ctx
216220
tr.logger.Error("failed to publish initial InProgress job status", zap.String("response", string(responseJson)), zap.Error(err))
217221
return err

0 commit comments

Comments
 (0)