From f23ec0d3f5a425031823e5d6da54641735be4c1a Mon Sep 17 00:00:00 2001 From: Tom Arnfeld Date: Tue, 14 Oct 2014 12:45:07 +0100 Subject: [PATCH 1/2] Fill out the FrameworkInfo hostname if missing --- pesos/scheduler.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pesos/scheduler.py b/pesos/scheduler.py index 9a0eba1..7f46e9f 100644 --- a/pesos/scheduler.py +++ b/pesos/scheduler.py @@ -364,6 +364,10 @@ def __init__(self, scheduler, framework, master_uri, credential=None, context=No self.detector = None self.credential = credential + # Fill out any missing FrameworkInfo values + if not self.framework.hostname: + self.framework.hostname = socket.getfqdn() + def locked(method): @functools.wraps(method) def _wrapper(self, *args, **kw): From 704e0a349b84e138aea3b6ba2adb79a2b5f2d168 Mon Sep 17 00:00:00 2001 From: Tom Arnfeld Date: Tue, 14 Oct 2014 12:45:37 +0100 Subject: [PATCH 2/2] Fill out the FrameworkInfo user if missing --- pesos/scheduler.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pesos/scheduler.py b/pesos/scheduler.py index 7f46e9f..60e6baa 100644 --- a/pesos/scheduler.py +++ b/pesos/scheduler.py @@ -367,6 +367,8 @@ def __init__(self, scheduler, framework, master_uri, credential=None, context=No # Fill out any missing FrameworkInfo values if not self.framework.hostname: self.framework.hostname = socket.getfqdn() + if not self.framework.user: + self.framework.user = getuser() def locked(method): @functools.wraps(method)