diff --git a/internal/services/cio/cio.go b/internal/services/cio/cio.go
index dbb0f0e7..328c3ed7 100644
--- a/internal/services/cio/cio.go
+++ b/internal/services/cio/cio.go
@@ -40,11 +40,12 @@ func (s *Service) SoftwareDisconnectionEvent(ctx context.Context, vehicleID uint
 	})
 	if err != nil {
 		s.logger.Err(err).Str("wallet_address", common.Bytes2Hex(address)).Msg("failed to get account by wallet address from accounts api")
+		return err
 	}
 
 	return s.client.Enqueue(
 		analytics.Identify{
-			UserId: account.Id,
+			UserId: account.GetId(),
 			Traits: analytics.NewTraits().Set("integration_id", integrationID).Set("vehicle_id", vehicleID),
 		},
 	)
diff --git a/internal/services/task_status_listener.go b/internal/services/task_status_listener.go
index 740a573c..209baa4f 100644
--- a/internal/services/task_status_listener.go
+++ b/internal/services/task_status_listener.go
@@ -129,7 +129,8 @@ func (i *TaskStatusListener) processSmartcarPollStatusEvent(event *shared.CloudE
 
 	vehicleID, ok := udai.R.UserDevice.TokenID.Uint64()
 	if !ok {
-		i.log.Err(errors.New("failed to parse vehicle token id for cio event"))
+		err := errors.New("failed to parse vehicle token id for cio event")
+		i.log.Err(err).Str("userDeviceID", userDeviceID).Str("integrationID", integrationID).Msg("invalid vehicle id")
 	}
 
 	return i.cioSvc.SoftwareDisconnectionEvent(ctx, vehicleID, udai.R.UserDevice.OwnerAddress.Bytes, integrationID)