should be better now

Dockerfile

@@ -12,5 +12,5 @@ RUN pip install --no-cache-dir --upgrade -r requirements.txt
 
 COPY --chown=user . .
 
-CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860", "--log-level", "info"]
 

app.py

@@ -64,7 +64,6 @@ async def post_webhook(
     task_queue: BackgroundTasks,
     x_webhook_secret: Optional[str] = Header(default=None),
 ):
-    return
     logger.info("Received new hook!")
     if x_webhook_secret is None:
         logger.warning("HTTP 401: No webhook secret")
@@ -84,15 +83,19 @@ async def post_webhook(
         and payload.event.action == "create"
         and payload.discussion is not None
         and payload.discussion.isPullRequest
+        and payload.discussion.status == "open"
     ):
         # New PR!
-        task_queue.add_task(
-            sync_ci_space,
-            space_id=space_id,
-            pr_num=payload.discussion.num,
-            private=payload.repo.private,
-        )
-        logger.info("New PR! Sync task scheduled")
+        if not is_pr_synced(space_id=space_id, pr_num=payload.discussion.num):
+            task_queue.add_task(
+                sync_ci_space,
+                space_id=space_id,
+                pr_num=payload.discussion.num,
+                private=payload.repo.private,
+            )
+            logger.info("New PR! Sync task scheduled")
+        else:
+            logger.info("New comment on PR but CI space already synced")
     elif (
         payload.event.scope.startswith("discussion")
         and payload.event.action == "update"
@@ -117,7 +120,6 @@ async def post_webhook(
         for discussion in get_repo_discussions(
             repo_id=space_id, repo_type="space", token=HF_TOKEN
         ):
-            break
             if discussion.is_pull_request and discussion.status == "open":
                 if not is_pr_synced(space_id=space_id, pr_num=discussion.num):
                     task_queue.add_task(
@@ -138,8 +140,13 @@ async def post_webhook(
 def is_pr_synced(space_id: str, pr_num: int) -> bool:
     # What is the last synced commit for this PR?
     ci_space_id = _get_ci_space_id(space_id=space_id, pr_num=pr_num)
-    card = RepoCard.load(repo_id_or_path=ci_space_id, repo_type="space", token=HF_TOKEN)
-    last_synced_sha = getattr(card.data, "synced_sha", None)
+    try:
+        card = RepoCard.load(
+            repo_id_or_path=ci_space_id, repo_type="space", token=HF_TOKEN
+        )
+        last_synced_sha = getattr(card.data, "synced_sha", None)
+    except HTTPError:
+        last_synced_sha = None
 
     # What is the last commit id for this PR?
     info = space_info(repo_id=space_id, revision=f"refs/pr/{pr_num}")