From f58b09a0647f28ecda0b4753ce553d22539338c4 Mon Sep 17 00:00:00 2001 From: Jake Moshenko Date: Mon, 5 Jan 2015 13:08:25 -0500 Subject: [PATCH] Remove the loop argument from the call to build_component_ready. --- buildman/component/buildcomponent.py | 3 +-- buildman/manager/ephemeral.py | 1 - 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/buildman/component/buildcomponent.py b/buildman/component/buildcomponent.py index 42e6696f2..c31d7aafe 100644 --- a/buildman/component/buildcomponent.py +++ b/buildman/component/buildcomponent.py @@ -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 diff --git a/buildman/manager/ephemeral.py b/buildman/manager/ephemeral.py index aa9bb7193..c7a084888 100644 --- a/buildman/manager/ephemeral.py +++ b/buildman/manager/ephemeral.py @@ -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)