temp: remove step run events

hatchet-dev · Jan 8, 2025 · 78e70b0 · 78e70b0
1 parent 740081b
commit 78e70b0
Showing 1 changed file with 32 additions and 30 deletions.
diff --git a/pkg/repository/prisma/buffer_step_run_events.go b/pkg/repository/prisma/buffer_step_run_events.go
@@ -205,42 +205,44 @@ func bulkStepRunEvents(
 	messages []string,
 	data []map[string]interface{},
 ) error {
-	inputData := [][]byte{}
-	inputReasons := []string{}
-	inputSeverities := []string{}
+	return nil
 
-	for _, d := range data {
-		dataBytes, err := json.Marshal(d)
+	// inputData := [][]byte{}
+	// inputReasons := []string{}
+	// inputSeverities := []string{}
 
-		if err != nil {
-			l.Err(err).Msg("could not marshal deferred step run event data")
-			return err
-		}
+	// for _, d := range data {
+	// 	dataBytes, err := json.Marshal(d)
 
-		inputData = append(inputData, dataBytes)
-	}
+	// 	if err != nil {
+	// 		l.Err(err).Msg("could not marshal deferred step run event data")
+	// 		return err
+	// 	}
 
-	for _, r := range reasons {
-		inputReasons = append(inputReasons, string(r))
-	}
+	// 	inputData = append(inputData, dataBytes)
+	// }
 
-	for _, s := range severities {
-		inputSeverities = append(inputSeverities, string(s))
-	}
+	// for _, r := range reasons {
+	// 	inputReasons = append(inputReasons, string(r))
+	// }
 
-	err := queries.BulkCreateStepRunEvent(ctx, dbtx, dbsqlc.BulkCreateStepRunEventParams{
-		Steprunids: stepRunIds,
-		Reasons:    inputReasons,
-		Severities: inputSeverities,
-		Messages:   messages,
-		Data:       inputData,
-		Timeseen:   timeSeen,
-	})
+	// for _, s := range severities {
+	// 	inputSeverities = append(inputSeverities, string(s))
+	// }
 
-	if err != nil {
-		l.Error().Err(err).Msg("could not create deferred step run event")
-		return fmt.Errorf("bulk_events - could not create deferred step run event: %w", err)
-	}
+	// err := queries.BulkCreateStepRunEvent(ctx, dbtx, dbsqlc.BulkCreateStepRunEventParams{
+	// 	Steprunids: stepRunIds,
+	// 	Reasons:    inputReasons,
+	// 	Severities: inputSeverities,
+	// 	Messages:   messages,
+	// 	Data:       inputData,
+	// 	Timeseen:   timeSeen,
+	// })
 
-	return nil
+	// if err != nil {
+	// 	l.Error().Err(err).Msg("could not create deferred step run event")
+	// 	return fmt.Errorf("bulk_events - could not create deferred step run event: %w", err)
+	// }
+
+	// return nil
 }