Riak example works

This commit is contained in:
Jedrzej Nowak 2015-10-31 21:40:07 +01:00
parent 9843a0652a
commit a89e067379
2 changed files with 2 additions and 2 deletions

View File

@ -35,7 +35,6 @@ from solar.dblayer.solar_models import Resource
def setup_riak():
# db.clear()
db.clear()
ModelMeta.remove_all()
resources = vr.create('nodes', 'templates/nodes.yaml', {'count': 3})
nodes = [x for x in resources if x.name.startswith('node')]

View File

@ -158,7 +158,7 @@ class Resource(object):
@property
def args(self):
return self.db_obj.inputs
return self.db_obj.inputs.as_dict()
# ret = {}
# for i in self.resource_inputs().values():
# ret[i.name] = i.backtrack_value()
@ -220,6 +220,7 @@ class Resource(object):
stored as:
[(emitter, emitter_input, receiver, receiver_input), ...]
"""
return []
rst = []
# TODO: fix it
for (emitter_resource, emitter_input), (receiver_resource, receiver_input), meta in self.graph().edges(data=True):