Не работает DELETE для "повторяющихся" строк

SELECT a.* FROM Weather a,
(SELECT * FROM Weather) b
WHERE a.ID_MD = b.ID_MD AND a.DT = b.DT AND a.LAT = b.LAT AND a.LON = b.LON AND a.SOURCE = b.SOURCE AND a.QUAL > b.QUAL AND NOT ISNULL(a.ZNCH) AND NOT ISNULL(b.ZNCH)

DELETE Weather.*
FROM Weather 
WHERE id IN (SELECT 
  Weather.id
FROM
  (SELECT Weather.ID_MD,--Соберем крайние значения 
          Weather.DT,
          Weather.LAT,
          Weather.LON,
          Weather.SOURCE,
          MIN(Weather.QUAL) AS minQUAL,
          MAX(Weather.UDT) AS maxUDT,
          COUNT(*) AS nCount
   FROM
     (SELECT ID_MD, --Данные которые поменяли
             SOURCE,
             DT
      FROM Weather_Update
      GROUP BY ID_MD,
               SOURCE,
               DT) AS qUpdate
   INNER JOIN Weather ON 
     qUpdate.ID_MD = Weather.ID_MD
     AND qUpdate.Source = Weather.Source
     AND qUpdate.dt = Weather.dt
   WHERE Weather.ZNCH IS NOT NULL
   GROUP BY Weather.ID_MD,
            Weather.DT,
            Weather.LAT,
            Weather.LON,
            Weather.SOURCE
   HAVING COUNT(*) > 1) AS qAgg
INNER JOIN Weather ON --Отберем значения которые больше не нужны
 
  (qAgg.SOURCE = Weather.SOURCE)
AND (qAgg.LON = Weather.LON)
AND (qAgg.LAT = Weather.LAT)
AND (qAgg.DT = Weather.DT)
AND (qAgg.ID_MD = Weather.ID_MD)
WHERE (((Weather.QUAL)>[qAgg].[minQUAL]) --Имеют худшее качесвто
       AND ((Weather.ZNCH) IS NOT NULL))
  OR (((Weather.QUAL)=[qAgg].[minQUAL]) --Имеют то же качество, но загружены раньше. (Оставляем свежие)
      AND ((Weather.ZNCH) IS NOT NULL)
      AND ((Weather.UDT)<[qAgg].[maxUDT])));

DELETE * FROM Weather_Update;

DROP INDEX IX ON Weather;

CREATE INDEX IX ON Weather (ID_MD,DT,SOURCE,LAT,LON);

.open Weather.db

--Таблица с данными
CREATE TABLE Weather (ID_MD INTEGER, DT FLOAT, LAT INTEGER, LAN INTEGER, SOURCE INTEGER, ZNCH FLOAT, UDT FLOAT, QUAL INTEGER, PDT INTEGER);
 
--Индекс для отслеживания дублей
CREATE UNIQUE INDEX Weather_UIDX ON Weather(ID_MD, DT, LAT, LAN, SOURCE);
 
--Представления для вставки данных по нашим правилам
CREATE VIEW weather_import AS SELECT * FROM weather;
 
--Вся магия творится тут. При обнаружении конфликта обновляем данные только в случае если качество выше или пришли более свежие данные
CREATE TRIGGER IF NOT EXISTS weather_insert instead OF INSERT ON weather_import FOR each ROW 
BEGIN
  INSERT INTO Weather(ID_MD, DT, LAT, LAN, SOURCE, ZNCH, UDT, QUAL, PDT)
  VALUES(NEW.ID_MD, NEW.DT, NEW.LAT, NEW.LAN, NEW.SOURCE, NEW.ZNCH, NEW.UDT, NEW.QUAL, NEW.PDT)
  ON CONFLICT DO UPDATE SET
    ZNCH=excluded.ZNCH,
    UDT=excluded.UDT,
    QUAL=excluded.QUAL,
    PDT=excluded.PDT
  WHERE 
    Weather.ID_MD = excluded.ID_MD AND
    Weather.DT = excluded.DT AND
    Weather.LAT = excluded.LAT AND
    Weather.LAN = excluded.LAN AND
    Weather.SOURCE = excluded.SOURCE AND
    (excluded.Qual < Weather.Qual OR
     (
       excluded.Qual = Weather.Qual AND 
       excluded.UDT > Weather.UDT
     )
    );
END;

.mode csv weather_import
.separator ;
.import c:\Users\USER\Documents\Weather.csv weather_import
.mode TABLE

(excluded.UDT > Weather.UDT OR
 (excluded.UDT = Weather.UDT AND excluded.Qual < Weather.Qual)
)