Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions src/user/tasks.py
Original file line number Diff line number Diff line change
@@ -1,14 +1,16 @@
import logging

from django.apps import apps
from django.core.cache import cache
from django_opensearch_dsl.registries import registry

from discussion.models import Vote
from paper.models import Paper
from researchhub.celery import QUEUE_ELASTIC_SEARCH, app
from researchhub.settings import APP_ENV
from user.editor_payout_tasks import editor_daily_payout_task
from user.rsc_exchange_rate_record_tasks import rsc_exchange_rate_record_tasks
from utils.sentry import log_info

logger = logging.getLogger(__name__)


@app.task
Expand Down Expand Up @@ -96,17 +98,15 @@ def update_elastic_registry(user_id):

@app.task
def execute_editor_daily_payout_task():
log_info(f"{APP_ENV}-running payout")
result = editor_daily_payout_task()
log_info(f"{APP_ENV}-running payout result: {str(result)}")
logger.info(f"Completed editor_daily_payout_task with result: {str(result)}")
return result


@app.task
def execute_rsc_exchange_rate_record_tasks():
log_info(f"{APP_ENV}-running rsc_exchange_rate_record_tasks")
result = rsc_exchange_rate_record_tasks()
log_info(f"{APP_ENV}-running rsc_exchange_rate_record_tasks result: {str(result)}")
logger.info(f"Completed rsc_exchange_rate_record_tasks with result: {str(result)}")


@app.task
Expand Down
Loading