diff --git a/daemons/ganeti-cleaner.in b/daemons/ganeti-cleaner.in
index ad0dd3b3a1859cd7c6a91ae1506d5fc3671cc415..1874b165eda1d68748a41bdae2bab7b216a7d153 100755
--- a/daemons/ganeti-cleaner.in
+++ b/daemons/ganeti-cleaner.in
@@ -20,20 +20,43 @@
 
 set -e
 
+cleanup_master() {
+  # Return if machine is not part of a cluster
+  [[ -e $DATA_DIR/ssconf_master_node ]] || return 0
+
+  # Return if queue archive directory doesn't exist
+  [[ -d $QUEUE_ARCHIVE_DIR ]] || return 0
+
+  # Remove old jobs
+  find $QUEUE_ARCHIVE_DIR -mindepth 2 -type f -mtime +$REMOVE_AFTER -print0 | \
+  xargs -r0 rm -vf
+}
+
 DATA_DIR=@LOCALSTATEDIR@/lib/ganeti
+CLEANER_LOG_DIR=@LOCALSTATEDIR@/log/ganeti/cleaner
 QUEUE_ARCHIVE_DIR=$DATA_DIR/queue/archive
 
 # Define how many days archived jobs should be left alone
 REMOVE_AFTER=21
 
-# Exit if machine is not part of a cluster
-[[ -e $DATA_DIR/ssconf_master_node ]] || exit 0
+# Define how many log files to keep around (usually one per day)
+KEEP_LOGS=50
+
+# Log file for this run
+LOG_FILE=$CLEANER_LOG_DIR/cleaner-$(date +'%Y-%m-%dT%H_%M').$$.log
+
+# Create log directory
+mkdir -p $CLEANER_LOG_DIR
+
+# Redirect all output to log file
+exec >>$LOG_FILE 2>&1
+
+echo "Cleaner started at $(date)"
 
-# Exit if queue archive directory doesn't exist
-[[ -d $QUEUE_ARCHIVE_DIR ]] || exit 0
+# Remove old cleaner log files
+find $CLEANER_LOG_DIR -maxdepth 1 -type f | sort | head -n -$KEEP_LOGS | \
+xargs -r rm -vf
 
-# Remove old jobs
-find $QUEUE_ARCHIVE_DIR -mindepth 2 -type f -mtime +$REMOVE_AFTER -print0 | \
-xargs -r0 rm -f
+cleanup_master
 
 exit 0
diff --git a/lib/rapi/client.py b/lib/rapi/client.py
index 298640e085b0b94443f95826590d26d24340d690..262e3893e9b77732c62d271f1bcbcfe090163b89 100644
--- a/lib/rapi/client.py
+++ b/lib/rapi/client.py
@@ -419,6 +419,8 @@ class GanetiRapiClient(object):
       encoded_response_content = resp.read()
     except (OpenSSL.SSL.Error, OpenSSL.crypto.Error), err:
       raise CertificateError("SSL issue: %s (%r)" % (err, err))
+    except urllib2.HTTPError, err:
+      raise GanetiApiError(str(err), code=err.code)
 
     if encoded_response_content:
       response_content = simplejson.loads(encoded_response_content)