diff --git a/iaai_scraper/worker/self_heal.py b/iaai_scraper/worker/self_heal.py
index 882a086..1da33c9 100644
--- a/iaai_scraper/worker/self_heal.py
+++ b/iaai_scraper/worker/self_heal.py
@@ -10,6 +10,7 @@ from redis import Redis
 
 logger = logging.getLogger("iaai_scraper.worker.self_heal")
 
+IAAI_SYNC_QUEUE = "iaai_sync"
 GLOBAL_PROGRESS_TS_KEY = "iaai:state:last_progress_ts"
 SELF_HEAL_RESTART_LOCK_KEY = "iaai:state:self_heal_restart_in_progress"
 SYNC_LISTING_LOCK_KEY = "iaai:locks:sync_listing"
@@ -131,7 +132,7 @@ def main() -> None:
 		logger.info("Self-heal watchdog disabled via IAAI_SELF_HEAL_ENABLED")
 		return
 
-	queue_name = os.getenv("IAAI_CELERY_QUEUE", "scraping")
+	queue_name = os.getenv("IAAI_CELERY_QUEUE", IAAI_SYNC_QUEUE)
 	check_interval = max(5, _env_int("IAAI_SELF_HEAL_CHECK_INTERVAL_SECONDS", 30))
 	stall_seconds = max(180, _env_int("IAAI_SELF_HEAL_STALL_SECONDS", 720))
 	startup_grace = max(30, _env_int("IAAI_SELF_HEAL_STARTUP_GRACE_SECONDS", 300))