From bba4c0712f7e02cfff6ec00dc11bd536d5bd59dd Mon Sep 17 00:00:00 2001 From: Mahan Zendedel DH Date: Wed, 27 Dec 2023 16:20:24 +0400 Subject: [PATCH] fix: add logs --- pkg/pipeline/sender.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/pipeline/sender.go b/pkg/pipeline/sender.go index 1986210..186e117 100644 --- a/pkg/pipeline/sender.go +++ b/pkg/pipeline/sender.go @@ -66,7 +66,7 @@ func SendToPipeline(ingestionPipelineEndpoint string, resourcesToSend []kafka.Do bodyStr = string(bodyBytes) } } - return fmt.Errorf("failed to send resources to OpenSearch, statusCode=%d, body=%s", resp.StatusCode, bodyStr) + return fmt.Errorf("failed to send resources to OpenSearch, statusCode=%d, body=%s, requestSize=%d", resp.StatusCode, bodyStr, len(jsonResourcesToSend)) } } return nil