'Returns the fanout task taking priority in account.
:param priority: the priority of the task
:param feed_class: the feed_class the task will write to'

def get_fanout_task(self, priority=None, feed_class=None):

    return self.priority_fanout_task.get(priority, fanout_operation)
