class MyTask(PeriodicTask):

    def run(self, **kwargs):
        logger = self.get_logger(**kwargs)
logger.info('Running my task')

def is_due(self, last_run_at):
    if random.random() < 0.5:
        return True, 60
django celery: как программно настроить задачу для запуска с определенным интервалом