When the etcd key tracking realms is first created the action is create, not set.

This commit is contained in:
Jake Moshenko 2014-12-31 11:46:02 -05:00
parent cc70225043
commit a9839021af
2 changed files with 2 additions and 2 deletions

View file

@ -96,7 +96,7 @@ class EphemeralBuilderManager(BaseManager):
async(self._clean_up_old_builder(etcd_result.key, job_metadata))
def _handle_realm_change(self, etcd_result):
if etcd_result.action == EtcdAction.SET:
if etcd_result.action == EtcdAction.CREATE:
# We must listen on the realm created by ourselves or another worker
realm_spec = json.loads(etcd_result.value)
component = self.register_component(realm_spec['realm'], BuildComponent,