asd

(cherry picked from commit 29f227a)
vplan-fr · Nov 4, 2024 · 60b8851 · 60b8851
1 parent 96413e4
commit 60b8851
Showing 1 changed file with 18 additions and 12 deletions.
diff --git a/backend/load_plans.py b/backend/load_plans.py
@@ -47,29 +47,35 @@ async def check_infinite(self, interval: int = 60, *, once: bool = False, ignore
                 updated_dates = await self.plan_downloader.update_fetch()
 
                 def _process_plans(t_start: datetime.datetime):
-                    self._plan_compute_executor.map(
-                        self.plan_processor.update_day_plans, updated_dates
-                    )
-                    self.plan_processor.update_after_plan_processing()
-                    events.submit_event(
-                        events.PlanCrawlCycle(
-                            school_number=self.school_number,
-                            start_time=t_start,
-                            end_time=events.now(),
+                    try:
+                        self._plan_compute_executor.map(
+                            self.plan_processor.update_day_plans, updated_dates
                         )
-                    )
+                        self.plan_processor.update_after_plan_processing()
+                        events.submit_event(
+                            events.PlanCrawlCycle(
+                                school_number=self.school_number,
+                                start_time=t_start,
+                                end_time=events.now(),
+                            )
+                        )
+                    except Exception:
+                        if not ignore_exceptions:
+                            raise
+                        else:
+                            self.plan_processor._logger.error("An error occurred (_process_plans).", exc_info=True)
 
                 if updated_dates:
                     self.plan_processor._logger.debug("* Processing plans...")
                     self.plan_processor.meta_extractor.invalidate_cache()
                     self._plan_compute_awaiter_executor.submit(_process_plans, t_start=_t1)
                 else:
                     self.plan_processor._logger.debug("* No plans to process.")
-            except Exception as e:
+            except Exception:
                 if not ignore_exceptions:
                     raise
                 else:
-                    self.plan_processor._logger.error("An error occurred.", exc_info=e)
+                    self.plan_processor._logger.error("An error occurred.", exc_info=True)
 
             if once:
                 break