  from collections import defaultdict
  from concurrent.futures import Future, ProcessPoolExecutor
  from datetime import datetime
  from enum import IntEnum
  from typing import List, Optional
  
  import numpy as np
  
  from cereal import log, messaging
  from common.params import Params, put_nonblocking
 
</s> remove     self.assertEqual(375, len(correct_msgs))
    self.assertEqual(375, len([m for m in correct_msgs if m.gnssMeasurements.positionECEF.valid]))
 </s> add     expected_msgs = 376
    self.assertEqual(expected_msgs, len(correct_msgs))
    self.assertEqual(expected_msgs, len([m for m in correct_msgs if m.gnssMeasurements.positionECEF.valid])) </s> remove       self.assertEqual(correct_msgs_expected, len([m for m in correct_msgs if m.gnssMeasurements.positionECEF.valid]))
 </s> add       self.assertEqual(valid_fix_expected, len([m for m in correct_msgs if m.gnssMeasurements.positionECEF.valid])) </s> remove       correct_msgs_expected = 42 if use_qcom else 559
 </s> add       correct_msgs_expected = 44 if use_qcom else 560
      valid_fix_expected = 43 if use_qcom else 560
 </s> remove     correct_msgs_expected = 559
 </s> add     correct_msgs_expected = 560 </s> remove       if len(est_pos) > 0:
 </s> add       if est_pos is not None and len(est_pos) > 0:
from typing import List, Optional, Dict, Any
  from collections import defaultdict
  from concurrent.futures import Future, ProcessPoolExecutor
  from datetime import datetime
  from enum import IntEnum
from typing import List, Optional, Dict, Any
  
  import numpy as np
  
  from cereal import log, messaging
  from common.params import Params, put_nonblocking
keep keep keep keep replace keep keep keep keep keep
 Laika cleaner flow (#27633)

* laika flow

* test fixes

* unexpected type

* unexpected type

* explicit type

* ref commit

* back to prev val

* ref 2 
selfdrive/locationd/laikad.py