def METHOD_NAME(self, headers_to_use, body_to_use):
    """
    Simple utility to call the pre-run handle and ensure it created a single task
    instance
    """
    self.assertEqual(PaperlessTask.objects.all().count(), 0)
    before_task_publish_handler(headers=headers_to_use, body=body_to_use)
    self.assertEqual(PaperlessTask.objects.all().count(), 1)