Check if report exist when celery task failed

docs/source/others/changelog.rst

@@ -2,6 +2,16 @@
 Changelog
 ==========
 
+
+2023.10.1+dev  (XXXX-XX-XX)
+---------------------------
+
+**Bugfix**
+
+- Check if report existing to update it when celery task fail
+- Source auto refresh exclude PENDING source now
+
+
 2023.10.1      (2023-10-01)
 ---------------------------
 

project/geosource/periodics.py

@@ -7,7 +7,7 @@
 
 def auto_refresh_source():
     countdown = 0
-    for source in Source.objects.all():
+    for source in Source.objects.exclude(status=Source.Status.PENDING):
         logger.info(f"Is refresh for {source}<{source.id}> needed?")
         if source.should_refresh():
             logger.info(f"Schedule refresh for source {source}<{source.id}>...")

project/geosource/tasks.py

@@ -20,7 +20,7 @@ def set_failure_state(task, method, message, instance=None):
         },
     }
     task.update_state(**state)
-    if instance and hasattr(instance, "report"):
+    if instance and hasattr(instance, "report") and instance.report is not None:
         text = ""
         for key, value in state["meta"].items():
             text += f"{key}: {value},"