Merge pull request #91 from xarses/various-fixes
load_all fix to reconnect all resources
This commit is contained in:
commit
092ede3de0
@ -185,7 +185,7 @@ def load_all():
|
|||||||
resource = wrap_resource(raw_resource)
|
resource = wrap_resource(raw_resource)
|
||||||
ret[resource.name] = resource
|
ret[resource.name] = resource
|
||||||
|
|
||||||
#signals.Connections.reconnect_all()
|
signals.Connections.reconnect_all()
|
||||||
|
|
||||||
return ret
|
return ret
|
||||||
|
|
||||||
|
@ -145,12 +145,9 @@ input:
|
|||||||
self.assertEqual(sample2.args['ip'], sample.args['ip'])
|
self.assertEqual(sample2.args['ip'], sample.args['ip'])
|
||||||
# sample should be unsubscribed from sample1 and subscribed to sample2
|
# sample should be unsubscribed from sample1 and subscribed to sample2
|
||||||
self.assertEqual(len(sample1.args['ip'].receivers), 0)
|
self.assertEqual(len(sample1.args['ip'].receivers), 0)
|
||||||
self.assertEqual(
|
self.assertEqual(sample.args['ip'].emitter, sample2.args['ip'])
|
||||||
sample.args['ip'].emitter,
|
|
||||||
sample2.args['ip']
|
|
||||||
)
|
|
||||||
|
|
||||||
sample1.update({'ip': '10.0.0.3'})
|
sample2.update({'ip': '10.0.0.3'})
|
||||||
self.assertEqual(sample2.args['ip'], sample.args['ip'])
|
self.assertEqual(sample2.args['ip'], sample.args['ip'])
|
||||||
|
|
||||||
def test_circular_connection_prevention(self):
|
def test_circular_connection_prevention(self):
|
||||||
@ -341,6 +338,11 @@ input:
|
|||||||
)
|
)
|
||||||
|
|
||||||
def test_nested_list_input(self):
|
def test_nested_list_input(self):
|
||||||
|
"""
|
||||||
|
Make sure that single input change is propagated along the chain of
|
||||||
|
lists.
|
||||||
|
"""
|
||||||
|
|
||||||
sample_meta_dir = self.make_resource_meta("""
|
sample_meta_dir = self.make_resource_meta("""
|
||||||
id: sample
|
id: sample
|
||||||
handler: ansible
|
handler: ansible
|
||||||
|
Loading…
x
Reference in New Issue
Block a user