varnitgoyal95/cybertron
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TP-5555 | error publishing kafka error remove

Browse Source
This commit is contained in:
varnit goyal
2025-01-09 16:17:56 +05:30
parent 5a32a8acee
commit 0307010d46
2 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/jobs/jobScheduler.go
View File

@@ -47,7 +47,6 @@ func esCleanUpJob(s *JobScheduler) {
rangeQuery := utils.CreateRangeQueryForLteString("created_at", sevenDaysAgo) rangeQuery := utils.CreateRangeQueryForLteString("created_at", sevenDaysAgo)
search_query := utils.CreateSearchQuery(rangeQuery) search_query := utils.CreateSearchQuery(rangeQuery)
es_query := utils.CreateEsQuery(search_query) es_query := utils.CreateEsQuery(search_query)
println("final query %v", es_query)
s.elasticSearchClient.DeleteDocuments(es_query) s.elasticSearchClient.DeleteDocuments(es_query)
} }

2
service/ExceptionService.go
View File

@@ -13,7 +13,6 @@ import (
"cybertron/pkg/metrics" "cybertron/pkg/metrics"
"cybertron/pkg/utils" "cybertron/pkg/utils"
"encoding/json" "encoding/json"
"fmt"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"gorm.io/gorm" "gorm.io/gorm"
"net/http" "net/http"
@@ -145,7 +144,6 @@ func (exceptionService *ExceptionService) CatchErrors(c *gin.Context) {
if err != nil { if err != nil {
exceptionService.logger.Error("Error publishing exception to Kafka: " + err.Error()) exceptionService.logger.Error("Error publishing exception to Kafka: " + err.Error())
fmt.Println("Failed to push error to kafka")
} }
} }