debug serveur status routing of scoring

Author: IdirLISN

src/apps/competitions/tasks.py

@@ -119,7 +119,19 @@
 
 
 def _send_to_compute_worker(submission, is_scoring, target_group=None):
+<<<<<<< HEAD
     logger.info("Site Worker ==> STARTING")
+=======
+    logger.info(
+        "Site Worker ==> STARTING submission_id=%s is_scoring=%s "
+        "target_group_param=%s submission.queue=%s parent=%s",
+        submission.pk,
+        is_scoring,
+        getattr(target_group, "pk", None),
+        getattr(getattr(submission, "queue", None), "name", None),
+        getattr(submission.parent, "pk", None) if submission.parent else None,
+    )
+>>>>>>> 0dc476f1 (debug serveur status routing of scoring)
 
     run_args = {
         "user_pk": submission.owner.pk,
@@ -285,6 +297,7 @@ def _send_to_compute_worker(submission, is_scoring, target_group=None):
     target_vhost = None
     try:
         if target_group:
+<<<<<<< HEAD
             if getattr(target_group, 'queue', None):
                 run_args['queue'] = target_group.queue.name
                 target_vhost = getattr(target_group.queue, 'vhost', None)
@@ -310,6 +323,111 @@ def _send_to_compute_worker(submission, is_scoring, target_group=None):
             else:
                 logger.debug("Submission %s owner %s: no matching group with queue for competition %s",
                              submission.pk, submission.owner.pk, competition.pk)
+=======
+            if getattr(target_group, "queue", None):
+                run_args["queue"] = target_group.queue.name
+                target_vhost = getattr(target_group.queue, "vhost", None)
+                try:
+                    submission.queue = target_group.queue
+                    submission.save(update_fields=["queue"])
+                    logger.debug("Persisted submission.queue=%s for submission %s", getattr(target_group.queue, "name", None), submission.pk)
+                except Exception:
+                    logger.exception("Failed to persist submission.queue for submission %s", submission.pk)
+            logger.info(
+                "Submission %s forced to group %s queue=%s vhost=%s",
+                submission.pk,
+                getattr(target_group, "pk", None),
+                run_args.get("queue"),
+                target_vhost,
+            )
+        else:
+            persisted_queue = None
+            try:
+                persisted_queue = getattr(submission, "queue", None)
+            except Exception:
+                persisted_queue = None
+
+            if persisted_queue:
+                try:
+                    run_args["queue"] = persisted_queue.name
+                    target_vhost = getattr(persisted_queue, "vhost", None)
+                    logger.info(
+                        "Submission %s resolved queue=%s vhost=%s (by persisted submission.queue)",
+                        submission.pk,
+                        run_args.get("queue"),
+                        target_vhost,
+                    )
+                except Exception:
+                    logger.exception("Error reading persisted submission.queue for submission %s", submission.pk)
+            else:
+                competition = submission.phase.competition
+                user_group_ids = list(submission.owner.groups.values_list("id", flat=True))
+                logger.debug(
+                    "User %s group ids for competition %s: %s",
+                    submission.owner.pk,
+                    competition.pk,
+                    user_group_ids,
+                )
+
+                comp_user_groups_qs = (
+                    competition.participant_groups
+                    .filter(id__in=user_group_ids)
+                    .select_related("queue")
+                )
+
+                group = (
+                    comp_user_groups_qs.filter(queue__isnull=False).first()
+                    or comp_user_groups_qs.first()
+                )
+
+                if group and getattr(group, "queue", None):
+                    run_args["queue"] = group.queue.name
+                    target_vhost = getattr(group.queue, "vhost", None)
+                    logger.info(
+                        "Submission %s resolved group=%s queue=%s vhost=%s (by owner membership)",
+                        submission.pk,
+                        group.pk,
+                        group.queue.name,
+                        target_vhost,
+                    )
+                else:
+                    logger.debug(
+                        "Submission %s: no matching group with queue for competition %s via owner membership",
+                        submission.pk,
+                        competition.pk,
+                    )
+
+                    if submission.parent:
+                        try:
+                            sibling = (
+                                Submission.objects
+                                .filter(parent=submission.parent)
+                                .exclude(pk=submission.pk)
+                                .filter(queue__isnull=False)
+                                .select_related("queue")
+                                .first()
+                            )
+                            if sibling and getattr(sibling, "queue", None):
+                                run_args["queue"] = sibling.queue.name
+                                target_vhost = getattr(sibling.queue, "vhost", None)
+                                # optionally persist to current child for future
+                                try:
+                                    submission.queue = sibling.queue
+                                    submission.save(update_fields=["queue"])
+                                    logger.debug("Persisted submission.queue from sibling=%s to submission=%s", sibling.pk, submission.pk)
+                                except Exception:
+                                    logger.exception("Failed to persist submission.queue (from sibling) for submission %s", submission.pk)
+
+                                logger.info(
+                                    "Submission %s resolved queue=%s vhost=%s (by sibling child %s)",
+                                    submission.pk,
+                                    run_args.get("queue"),
+                                    target_vhost,
+                                    sibling.pk,
+                                )
+                        except Exception:
+                            logger.exception("Error while trying to resolve queue from sibling for submission %s", submission.pk)
+>>>>>>> 0dc476f1 (debug serveur status routing of scoring)
     except Exception:
         logger.exception("Error while resolving competition/group for submission %s", submission.pk)