def get_fanout_task(self, priority=None, feed_class=None):
        return self.priority_fanout_task.get(priority, fanout_operation)
Returns the fanout task taking priority in account.
dataset/ETHPy150Open tschellenbach/Stream-Framework/stream_framework/feed_managers/base.py/Manager.get_fanout_task