fix: move task to new queue (#23313)

posthog/tasks/scheduled.py

@@ -223,6 +223,8 @@ def setup_periodic_tasks(sender: Celery, **kwargs: Any) -> None:
         name="process scheduled changes",
     )
 
+    add_periodic_task_with_expiry(sender, 3600, invalid_web_replays.s())
+
     if clear_clickhouse_crontab := get_crontab(settings.CLEAR_CLICKHOUSE_REMOVED_DATA_SCHEDULE_CRON):
         sender.add_periodic_task(
             clear_clickhouse_crontab,
@@ -314,14 +316,6 @@ def setup_periodic_tasks(sender: Celery, **kwargs: Any) -> None:
         check_data_import_row_limits.s(),
         name="check external data rows synced",
     )
-
-    add_periodic_task_with_expiry(
-        sender,
-        3600,
-        invalid_web_replays.s(),
-        name="Invalid web replays count",
-    )
-
     # Every 20 minutes try to retrieve and calculate total rows synced in period
 
     sender.add_periodic_task(

posthog/tasks/tasks.py

@@ -228,8 +228,10 @@ def ingestion_lag() -> None:
         pass
 
 
-@shared_task(ignore_result=True)
+@shared_task(ignore_result=True, queue=CeleryQueue.SESSION_REPLAY_GENERAL.value)
 def invalid_web_replays() -> None:
+    logger.info("[invalid web replays] running task")
+
     from posthog.client import sync_execute
 
     # ultimately I want to observe values by team id, but at the moment that would be lots of series, let's reduce the value first

posthog/tasks/utils.py

@@ -36,3 +36,4 @@ class CeleryQueue(Enum):
     USAGE_REPORTS = "usage_reports"
     SESSION_REPLAY_EMBEDDINGS = "session_replay_embeddings"
     SESSION_REPLAY_PERSISTENCE = "session_replay_persistence"
+    SESSION_REPLAY_GENERAL = "session_replay_general"