Remove the loop argument from the call to build_component_ready.

This commit is contained in:
Jake Moshenko 2015-01-05 13:08:25 -05:00
parent 320ae63ccd
commit f58b09a064
2 changed files with 1 additions and 3 deletions

View file

@ -314,8 +314,7 @@ class BuildComponent(BaseComponent):
@trollius.coroutine
def _set_status(self, phase):
if phase == ComponentStatus.RUNNING:
loop = trollius.get_event_loop()
yield trollius.From(self.parent_manager.build_component_ready(self, loop))
yield trollius.From(self.parent_manager.build_component_ready(self))
self._component_status = phase

View file

@ -66,7 +66,6 @@ class EphemeralBuilderManager(BaseManager):
def _watch_etcd(self, etcd_key, change_callback, recursive=True):
watch_task_key = (etcd_key, recursive)
def callback_wrapper(changed_key_future):
if watch_task_key not in self._watch_tasks or self._watch_tasks[watch_task_key].done():
self._watch_etcd(etcd_key, change_callback)