GlitchTip/projects/tasks.py

from celery import shared_task

from glitchtip.debounced_celery_task import debounced_task, debounced_wrap

from .models import (
    EventProjectHourlyStatistic,
    Project,
    TransactionEventProjectHourlyStatistic,
)


@debounced_task(lambda x, *a, **k: x)
@shared_task
@debounced_wrap
def update_event_project_hourly_statistic(project_id: int, start_time: str):
    EventProjectHourlyStatistic.update(project_id, start_time)


@debounced_task(lambda x, *a, **k: x)
@shared_task
@debounced_wrap
def update_transaction_event_project_hourly_statistic(project_id: int, start_time: str):
    TransactionEventProjectHourlyStatistic.update(project_id, start_time)


@shared_task
def delete_project(project_id: int):
    Project.objects.get(id=project_id).force_delete()