def data_source_count(self, context, **kwargs):
        return self.db.data_source_count(context, **kwargs)
current node
dataset/ETHPy150Open openstack/sahara/sahara/conductor/manager.py/ConductorManager.data_source_count--crossover with--dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/runtime/north/plugins/requirements/current_node.py/req_op