Moved some more info log entries to debug.

Author: apognu

usecases/custom_list_usecase.go

@@ -231,7 +231,7 @@ func (usecase *CustomListUseCase) ReplaceCustomListValuesFromCSV(ctx context.Con
 		duration := end.Sub(start)
 		// divide by 1e6 convert to milliseconds (base is nanoseconds)
 		avgDuration := float64(duration) / float64(total*1e6)
-		logger.InfoContext(ctx, fmt.Sprintf("Successfully ingested %d custom list values in %s, average %vms", total, duration, avgDuration))
+		logger.DebugContext(ctx, fmt.Sprintf("Successfully ingested %d custom list values in %s, average %vms", total, duration, avgDuration))
 	}
 	defer printDuration()
 

usecases/decision_usecase.go

@@ -527,12 +527,15 @@ func (usecase *DecisionUsecase) CreateDecision(
 		scenarioExecution.ExecutionMetrics.Steps[evaluate_scenario.LogStorageDurationKey] = storageDuration.Milliseconds()
 
 		utils.LoggerFromContext(ctx).InfoContext(ctx,
-			fmt.Sprintf("created decision %s in %dms", decision.DecisionId,
-				decisionDuration.Milliseconds()), "org_id", scenario.OrganizationId, "decision_id",
-			decision.DecisionId, "scenario_id", scenario.Id, "score", scenarioExecution.Score,
-			"outcome", scenarioExecution.Outcome, "duration", decisionDuration.Milliseconds(),
-			"rules", scenarioExecution.ExecutionMetrics.Rules, "steps",
-			scenarioExecution.ExecutionMetrics.Steps)
+			fmt.Sprintf("created decision %s in %dms", decision.DecisionId, decisionDuration.Milliseconds()),
+			"org_id", scenario.OrganizationId,
+			"decision_id", decision.DecisionId,
+			"scenario_id", scenario.Id,
+			"score", scenarioExecution.Score,
+			"outcome", scenarioExecution.Outcome,
+			"duration", decisionDuration.Milliseconds(),
+			"rules", scenarioExecution.ExecutionMetrics.Rules,
+			"steps", scenarioExecution.ExecutionMetrics.Steps)
 
 	}
 
@@ -676,13 +679,16 @@ func (usecase *DecisionUsecase) CreateAllDecisions(
 				item.execution.ExecutionMetrics.Steps[evaluate_scenario.LogStorageDurationKey] = storageDuration.Milliseconds()
 
 				utils.LoggerFromContext(ctx).InfoContext(ctx,
-					fmt.Sprintf("created decision (all) %s in %dms", item.decision.DecisionId,
-						decisionDuration.Milliseconds()), "org_id",
-					item.scenario.OrganizationId, "decision_id",
-					item.decision.DecisionId, "scenario_id", item.scenario.Id, "score", item.execution.Score,
-					"outcome", item.execution.Outcome, "duration", decisionDuration.Milliseconds(),
-					"rules", item.execution.ExecutionMetrics.Rules, "steps",
-					item.execution.ExecutionMetrics.Steps)
+					fmt.Sprintf("created decision (all) %s in %dms",
+						item.decision.DecisionId, decisionDuration.Milliseconds()),
+					"org_id", item.scenario.OrganizationId,
+					"decision_id", item.decision.DecisionId,
+					"scenario_id", item.scenario.Id,
+					"score", item.execution.Score,
+					"outcome", item.execution.Outcome,
+					"duration", decisionDuration.Milliseconds(),
+					"rules", item.execution.ExecutionMetrics.Rules,
+					"steps", item.execution.ExecutionMetrics.Steps)
 			}
 
 			webhookEventId := uuid.NewString()

usecases/evaluate_scenario/evaluate_scenario.go

@@ -314,7 +314,7 @@ func (e ScenarioEvaluator) EvalTestRunScenario(
 			se = models.ScenarioExecution{}
 		}
 	}()
-	logger.InfoContext(ctx, "Evaluating scenario test run", "scenarioId", params.Scenario.Id)
+	logger.DebugContext(ctx, "Evaluating scenario test run", "scenarioId", params.Scenario.Id)
 	exec := e.executorFactory.NewExecutor()
 	tracer := utils.OpenTelemetryTracerFromContext(ctx)
 	ctx, span := tracer.Start(ctx, "evaluate_scenario.EvalTestRunScenario",
@@ -395,7 +395,7 @@ func (e ScenarioEvaluator) EvalScenario(
 		}
 	}()
 
-	logger.InfoContext(ctx, "Evaluating scenario", "scenarioId", params.Scenario.Id)
+	logger.DebugContext(ctx, "Evaluating scenario", "scenarioId", params.Scenario.Id)
 	exec := e.executorFactory.NewExecutor()
 
 	// If the scenario has no live version, don't try to Eval() it, return early

usecases/ingestion_usecase.go

@@ -103,7 +103,7 @@ func (usecase *IngestionUseCase) IngestObject(
 		return 0, err
 	}
 
-	logger.InfoContext(ctx, fmt.Sprintf("Successfully ingested objects: %d objects", nb),
+	logger.DebugContext(ctx, fmt.Sprintf("Successfully ingested objects: %d objects", nb),
 		slog.String("organization_id", organizationId),
 		slog.String("object_type", objectType),
 		slog.Int("nb_objects", nb),
@@ -193,7 +193,7 @@ func (usecase *IngestionUseCase) IngestObjects(
 		return 0, err
 	}
 
-	logger.InfoContext(ctx, fmt.Sprintf("Successfully ingested objects: %d objects", nb),
+	logger.DebugContext(ctx, fmt.Sprintf("Successfully ingested objects: %d objects", nb),
 		slog.String("organization_id", organizationId),
 		slog.String("object_type", objectType),
 		slog.Int("nb_objects", nb),
@@ -493,7 +493,7 @@ func (usecase *IngestionUseCase) ingestObjectsFromCSV(ctx context.Context, organ
 		// divide by 1e6 convert to milliseconds (base is nanoseconds)
 		avgDuration := float64(duration) / float64(total*1e6)
 		if total > 0 {
-			logger.InfoContext(ctx, fmt.Sprintf("Successfully ingested %d objects in %s, average %vms", total, duration, avgDuration))
+			logger.DebugContext(ctx, fmt.Sprintf("Successfully ingested %d objects in %s, average %vms", total, duration, avgDuration))
 		}
 	}
 	defer printDuration()

usecases/scheduled_execution/async_decision_job.go

@@ -357,12 +357,15 @@ func (w *AsyncDecisionWorker) createSingleDecisionForObjectId(
 		scenarioExecution.ExecutionMetrics.Steps[evaluate_scenario.LogStorageDurationKey] = storageDuration.Milliseconds()
 
 		utils.LoggerFromContext(ctx).InfoContext(ctx,
-			fmt.Sprintf("created decision (async) %s in %dms", decision.DecisionId,
-				decisionDuration.Milliseconds()), "org_id", scenario.OrganizationId, "decision_id",
-			decision.DecisionId, "scenario_id", scenario.Id, "score", scenarioExecution.Score,
-			"outcome", scenarioExecution.Outcome, "duration", decisionDuration.Milliseconds(),
-			"rules", scenarioExecution.ExecutionMetrics.Rules, "steps",
-			scenarioExecution.ExecutionMetrics.Steps)
+			fmt.Sprintf("created decision (async) %s in %dms", decision.DecisionId, decisionDuration.Milliseconds()),
+			"org_id", scenario.OrganizationId,
+			"decision_id", decision.DecisionId,
+			"scenario_id", scenario.Id,
+			"score", scenarioExecution.Score,
+			"outcome", scenarioExecution.Outcome,
+			"duration", decisionDuration.Milliseconds(),
+			"rules", scenarioExecution.ExecutionMetrics.Rules,
+			"steps", scenarioExecution.ExecutionMetrics.Steps)
 	}
 
 	if decision.SanctionCheckExecution != nil {

usecases/webhook_events_usecase.go

@@ -213,7 +213,7 @@ func (usecase WebhookEventsUsecase) _sendWebhookEvent(ctx context.Context, webho
 		return models.Scheduled, err
 	}
 
-	logger.InfoContext(ctx, fmt.Sprintf("Start processing webhook event %s", webhookEvent.Id))
+	logger.DebugContext(ctx, fmt.Sprintf("Start processing webhook event %s", webhookEvent.Id))
 
 	webhookEventUpdate := models.WebhookEventUpdate{Id: webhookEvent.Id}