Skip to content

Commit a5a7a38

Browse files
committed
revert the first PR
1 parent 7c8aa8b commit a5a7a38

File tree

2 files changed

+104
-155
lines changed

2 files changed

+104
-155
lines changed

posthog/tasks/periodic_digest.py

-7
Original file line numberDiff line numberDiff line change
@@ -3,15 +3,12 @@
33
from typing import Any, Optional
44
from zoneinfo import ZoneInfo
55

6-
import celery
76
import structlog
87
from celery import shared_task
98
from dateutil import parser
109
from django.db.models import QuerySet
1110
from django.utils import timezone
1211
from posthoganalytics.client import Client
13-
14-
from posthog.clickhouse.query_tagging import tag_queries
1512
from posthog.exceptions_capture import capture_exception
1613

1714
from posthog.models.dashboard import Dashboard
@@ -263,8 +260,6 @@ def _get_all_org_digest_reports(period_start: datetime, period_end: datetime) ->
263260

264261
@shared_task(**USAGE_REPORT_TASK_KWARGS, max_retries=0)
265262
def send_all_periodic_digest_reports(
266-
self: celery.Task,
267-
*,
268263
dry_run: bool = False,
269264
end_date: Optional[str] = None,
270265
begin_date: Optional[str] = None,
@@ -276,8 +271,6 @@ def send_all_periodic_digest_reports(
276271
)
277272
period_start = parser.parse(begin_date) if begin_date else period_end - timedelta(days=7)
278273

279-
tag_queries(celery_request_id=self.request.id)
280-
281274
try:
282275
org_reports = _get_all_org_digest_reports(period_start, period_end)
283276
instance_metadata = dataclasses.asdict(get_instance_metadata((period_start, period_end)))

0 commit comments

Comments
 (0)