chore: add more logging

PeerDB-io · Dec 3, 2024 · 731fccf · 731fccf
1 parent ed229f0
commit 731fccf
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/flow/otel_metrics/otel_manager.go b/flow/otel_metrics/otel_manager.go
@@ -73,13 +73,18 @@ func getOrInitMetric[M any, O any](
 ) (M, error) {
 	gauge, ok := cache[name]
 	if !ok {
+		// TODO remove this post testing
+		slog.Info("Creating new metric", slog.String("name", name))
 		var err error
 		gauge, err = cons(meter, name, opts...)
 		if err != nil {
 			var none M
 			return none, err
 		}
 		cache[name] = gauge
+	} else {
+		// TODO remove this post testing
+		slog.Info("Found existing metric", slog.String("name", name))
 	}
 	return gauge, nil
 }

diff --git a/flow/workflows/scheduled_flows.go b/flow/workflows/scheduled_flows.go
@@ -55,7 +55,8 @@ func GlobalScheduleManagerWorkflow(ctx workflow.Context) error {
 
 	slotSizeCtx := withCronOptions(ctx,
 		"record-slot-size-"+info.OriginalRunID,
-		"*/5 * * * *")
+		// TODO revert this post testing
+		"* * * * *")
 	workflow.ExecuteChildWorkflow(slotSizeCtx, RecordSlotSizeWorkflow)
 
 	ctx.Done().Receive(ctx, nil)