driver-dispatch-bug

signadot · Jul 3, 2024 · 34c1f93 · 34c1f93
1 parent f5bfcbc
commit 34c1f93
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/services/driver/consumer.go b/services/driver/consumer.go
@@ -151,18 +151,18 @@ func (consumer *Consumer) processDispatchRequest(msg *sarama.ConsumerMessage) {
 	}
 
 	// get the driver with the best ETA
-	bestDriver, err := consumer.bestETA.Get(ctx, &dispatchReq, drivers)
+	_, err = consumer.bestETA.Get(ctx, &dispatchReq, drivers)
 	if err != nil {
 		consumer.logger.For(ctx).Error("error calculating best route", zap.Error(err))
 		span.SetStatus(codes.Error, err.Error())
 		return
 	}
 
 	// send a notification
-	consumer.notification.Store(ctx, &notifications.Notification{
-		ID:        fmt.Sprintf("req-%d-dispatched-driver", reqContext.ID),
-		Timestamp: time.Now(),
-		Context:   notificationCtx,
-		Body:      fmt.Sprintf("Driver %s arriving in %s", bestDriver.DriverID, bestDriver.ETA.String()),
-	})
+	// consumer.notification.Store(ctx, &notifications.Notification{
+	// 	ID:        fmt.Sprintf("req-%d-dispatched-driver", reqContext.ID),
+	// 	Timestamp: time.Now(),
+	// 	Context:   notificationCtx,
+	// 	Body:      fmt.Sprintf("Driver %s arriving in %s", bestDriver.DriverID, bestDriver.ETA.String()),
+	// })
 }