adding the correct names

Signed-off-by: Yashvi Jain <yashvi.jain@progress.com>

components/compliance-service/ingest/ingestic/ingestic.go

@@ -1222,9 +1222,6 @@ func (backend *ESClient) GetReportsDailyLatestTrue(ctx context.Context, upgradeT
 	boolQuery := elastic.NewBoolQuery().
 		Must(elastic.NewTermQuery("daily_latest", true)).Must(rangeQuery)
 
-	src, _ := boolQuery.Source()
-	logrus.Infof("Test Query For upgrade is noow : %v", src)
-
 	fsc := elastic.NewFetchSourceContext(true).Include(
 		"report_uuid",
 		"node_uuid",

components/compliance-service/migrations/migration_workflow.go

@@ -128,9 +128,9 @@ func (t *UpgradeTask) Run(ctx context.Context, task cereal.Task) (interface{}, e
 		return nil, err
 	}
 
-	logrus.Info("Inside the upgrades flag flow")
 	logrus.Infof("Upgrade started at time %v", time.Now())
 	if job.ControlFlag {
+
 		logrus.Info("Inside the control flag")
 		if err := performActionForUpgrade(ctx, t.ESClient, job.UpgradeDate); err != nil {
 			logrus.WithError(err).Error("Unable to upgrade control index flag for latest record ")
@@ -159,7 +159,7 @@ type ControlIndexUpgradeTask struct {
 
 func performActionForUpgrade(ctx context.Context, esClient *ingestic.ESClient, upgradeTime time.Time) error {
 	mapping := mappings.ComplianceRepDate
-	if time.Now().Sub(upgradeTime)/24 > 90 {
+	if time.Now().Sub(upgradeTime).Hours()/24 > 90 {
 		upgradeTime = time.Now().Add(-24 * time.Hour * 90)
 	}
 	reportsMap, latestReportsMap, err := esClient.GetReportsDailyLatestTrue(ctx, upgradeTime)

components/compliance-service/migrations/upgrades.go

@@ -21,7 +21,6 @@ func NewService(pg *pgdb.UpgradesDB, cerealManger *cereal.Manager) *Upgrade {
 }
 
 //PollForUpgradeFlagDayLatest checks for the day latest flag value in upgrade flags
-//TODO:: run the upgrade from current date to upgradeDate
 func (u *Upgrade) PollForUpgradeFlagDayLatest(upgradeDate time.Time) error {
 	logrus.Infof("upgrade will run from %s to till now", upgradeDate.String())
 	controlFlag, err := u.getUpgradeFlag(pgdb.ControlIndexFlag)