make sure celery task is imported

PostHog · Dec 26, 2023 · c602afe · c602afe
1 parent 51182ce
commit c602afe
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/posthog/celery.py b/posthog/celery.py
@@ -348,13 +348,6 @@ def setup_periodic_tasks(sender: Celery, **kwargs):
         name="sync datawarehouse sources that have settled in s3 bucket",
     )
 
-    # Every 30 minutes try to retrieve and calculate total rows synced in period
-    sender.add_periodic_task(
-        crontab(minute="*/30"),
-        calculate_external_data_rows_synced.s(),
-        name="calculate external data rows synced",
-    )
-
     sender.add_periodic_task(
         crontab(minute="23", hour="*"),
         check_data_import_row_limits.s(),

diff --git a/posthog/tasks/__init__.py b/posthog/tasks/__init__.py
@@ -12,6 +12,7 @@
     sync_all_organization_available_features,
     usage_report,
     user_identify,
+    warehouse,
 )
 
 __all__ = [
@@ -26,4 +27,5 @@
     "sync_all_organization_available_features",
     "user_identify",
     "usage_report",
+    "warehouse",
 ]