Don't relegate unimplemented jobs to dead letter queue.

scpwiki · Jan 14, 2024 · 92c8bb1 · 92c8bb1
1 parent 3e2eeae
commit 92c8bb1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/yellowstone/core.py b/yellowstone/core.py
@@ -100,6 +100,11 @@ def process_job(self, job: JobDict) -> None:
                     raise NotImplementedError
                 case JobType.INDEX_SITE_MEMBERS:
                     raise NotImplementedError
+        except NotImplementedError:
+            logger.error(
+                "Job hit not-yet-implemented component, not increasing attempt count",
+                exc_info=True,
+            )
         except Exception as _:
             logger.error("Error occurred while processing job", exc_info=True)
             if job["attempts"] < MAX_RETRIES: