]> git.donarmstrong.com Git - dsa-puppet.git/blobdiff - modules/porterbox/files/mail-big-homedirs
Avoid KeyError when uid > max_uid_logged_in
[dsa-puppet.git] / modules / porterbox / files / mail-big-homedirs
index 8b1d3cec0216b5210f6bf66b033594d3b380bc74..4211805532d91a25e06f4f6db404eb60edf06071 100755 (executable)
@@ -194,10 +194,19 @@ class HomedirReminder(object):
 
   def run(self):
     current_time = time.time()
+    conn = None
     try:
+      data = {}
+      for user in set(self.homedir_sizes.keys()) | \
+                  set(self.lastlog_times.keys()):
+        data[user] = {
+          'homedir': self.homedir_sizes.get(user, 0),
+          'lastlog': self.lastlog_times.get(user, 0),
+        }
+
       msg = {
         'timestamp': current_time,
-        'data': self.homedir_sizes,
+        'data': data,
         'host': platform.node(),
       }
       conn = Connection(conf=mq_conf)
@@ -206,7 +215,7 @@ class HomedirReminder(object):
                       exchange_name=config.exchange,
                       timeout=5)
     except Exception, e:
-      LOG.error("Error sending: %s" % e)
+      logging.error("Error sending: %s" % e)
     finally:
       if conn:
         conn.close()
@@ -216,7 +225,7 @@ class HomedirReminder(object):
         realname = pwd.getpwnam(username).pw_gecos.decode('utf-8').split(',', 1)[0]
       except:
         realname = username
-      lastlog_time = self.lastlog_times[username]
+      lastlog_time = self.lastlog_times.get(username, 0)
       days_ago = int( (current_time - lastlog_time) / 3600 / 24 )
       kwargs = {
           'hostname': platform.node(),