瀏覽代碼

[compute] [discovery] remove old computes before upserting

Amit Srivastava 8 月之前
父節點
當前提交
e0785b182d
共有 1 個文件被更改,包括 2 次插入2 次删除
  1. 2 2
      desktop/core/src/desktop/management/commands/sync_warehouses.py

+ 2 - 2
desktop/core/src/desktop/management/commands/sync_warehouses.py

@@ -87,11 +87,11 @@ def sync_warehouses(args, options):
 
 
 def add_computes_to_warehouse(warehouse, computes):
+  external_ids = [c['external_id'] for c in computes]
+  models.Compute.objects.filter(namespace=warehouse).exclude(external_id__in=external_ids).delete()
   for c in computes:
     c['namespace'] = warehouse
     models.Compute.objects.update_or_create(external_id=c['external_id'], defaults=c)
-  external_ids = [c['external_id'] for c in computes]
-  models.Compute.objects.filter(namespace=warehouse).exclude(external_id__in=external_ids).delete()
 
 
 if __name__ == '__main__':