|
@@ -14,6 +14,7 @@ def delay_task(task_name, **kwargs):
|
|
|
publisher.close()
|
|
|
return task_id
|
|
|
|
|
|
+
|
|
|
def discard_all():
|
|
|
consumer = TaskConsumer(connection=DjangoAMQPConnection)
|
|
|
discarded_count = consumer.discard_all()
|
|
@@ -63,15 +64,6 @@ class PeriodicTask(Task):
|
|
|
super(PeriodicTask, self).__init__()
|
|
|
|
|
|
|
|
|
-class TestPeriodicTask(PeriodicTask):
|
|
|
- name = "crunchy-test-periodic-task"
|
|
|
- run_every = 20
|
|
|
-
|
|
|
- def run(self, **kwargs):
|
|
|
- logger = setup_logger(**kwargs)
|
|
|
- logger.info("Running periodic task foo!")
|
|
|
-tasks.register(TestPeriodicTask)
|
|
|
-
|
|
|
class TestTask(Task):
|
|
|
name = "crunchy-test-task"
|
|
|
|