api/ants: prevent too long transactions when pushing rdvs (#83553)

src/ants_hub/api/ants.py

@@ -93,19 +93,21 @@ def get_rdvs_to_upload():
 
 def upload_rdvs():
     # get never uploaded rdvs and rdv uploaded which changed (cancelled)
-    with atomic():
-        rdvs = get_rdvs_to_upload().select_for_update(of=('self',)).distinct()
-        start = now()
-        pushed = set()
-        for rdv in rdvs:
+    rdvs = get_rdvs_to_upload()
+    start = now()
+    for rdv in rdvs.distinct():
+        with atomic():
+            try:
+                rdv = rdvs.select_for_update(of=('self',)).get(pk=rdv.pk)
+            except RendezVous.DoesNotExist:
+                continue
             try:
                 if push_rdv(rdv):
-                    pushed.add(rdv)
+                    logger.info('pushed rdv(%s) of lieu %s', rdv, rdv.lieu)
+                    rdv.last_upload = start
+                    rdv.save()
             except ANTSError as e:
                 logger.warning('unable to push rdv(%s) of lieu %s: %r', rdv, rdv.lieu, e)
-        rdvs.filter(pk__in=[rdv.pk for rdv in pushed]).update(last_upload=start)
-        for rdv in pushed:
-            logger.info('pushed rdv(%s) of lieu %s', rdv, rdv.lieu)
 
 
 def get_status_of_predemandes(identifiant_predemandes: list):