From 0efe1a744722a7ad667e54dde33b4d1bc916468f Mon Sep 17 00:00:00 2001 From: Tom Arnfeld Date: Tue, 14 Oct 2014 12:45:37 +0100 Subject: [PATCH] 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 1aff6e9..85eb25f 100644 --- a/pesos/scheduler.py +++ b/pesos/scheduler.py @@ -348,6 +348,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)