Fill out the FrameworkInfo user if missing

wickman · Oct 14, 2014 · 0efe1a7 · 0efe1a7
1 parent b12939c
commit 0efe1a7
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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)