Skip to content

Commit

Permalink
enh: add logging for to be celery invoked register_scheduled_tasks
Browse files Browse the repository at this point in the history
  • Loading branch information
yarikoptic committed Nov 20, 2024
1 parent 41f9435 commit dddec4c
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions dandiapi/api/tasks/scheduled.py
Original file line number Diff line number Diff line change
Expand Up @@ -129,6 +129,11 @@ def refresh_materialized_view_search() -> None:

def register_scheduled_tasks(sender: Celery, **kwargs):
"""Register tasks with a celery beat schedule."""
logger.info(
'Registering scheduled tasks for %s. ' 'DANDI_VALIDATION_JOB_INTERVAL is %s seconds.',
sender,
settings.DANDI_VALIDATION_JOB_INTERVAL,
)
# Check for any draft versions that need validation every minute
sender.add_periodic_task(
timedelta(seconds=settings.DANDI_VALIDATION_JOB_INTERVAL),
Expand Down

0 comments on commit dddec4c

Please sign in to comment.