""" Django Celery tasks for service status app """ import time from dogapi import dog_stats_api from djcelery import celery @celery.task @dog_stats_api.timed('status.service.celery.pong') def delayed_ping(value, delay): """A simple tasks that replies to a message after a especified amount of seconds. """ if value == 'ping': result = 'pong' else: result = 'got: {0}'.format(value) time.sleep(delay) return result