diff --git a/turbo_hipster/lib/utils.py b/turbo_hipster/lib/utils.py
index a693ff7..9d3ecff 100644
--- a/turbo_hipster/lib/utils.py
+++ b/turbo_hipster/lib/utils.py
@@ -139,6 +139,7 @@
 
     def process(fd):
         """ Write the fd to log """
+        global last_heartbeat
         descriptors[fd]['lines'] += os.read(fd, 1024 * 1024)
         # Avoid partial lines by only processing input with breaks
         if descriptors[fd]['lines'].find('\n') != -1:
@@ -177,8 +178,7 @@
     """ Push a log file to a server. Returns the public URL """
     method = publish_config['type'] + '_push_file'
     if method in locals():
-        return locals(method)(job_name, dataset['log_file_path'],
-                              publish_config)
+        return locals(method)(job_name, file_path, publish_config)
 
 
 def swift_push_file(job_name, file_path, swift_config):
diff --git a/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py b/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py
index 3bac8c6..6cf332e 100644
--- a/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py
+++ b/turbo_hipster/task_plugins/gate_real_db_upgrade/handle_results.py
@@ -46,10 +46,11 @@
                                        publish_config))
         datasets[i]['files'] = files
 
-    index_file = make_index_file(datasets)
+    #index_file = make_index_file(datasets)
     #index_file_url = push_file(index_file)
 
     return files[0]
 
+
 def check_log_for_errors(logfile):
-    return True
\ No newline at end of file
+    return True
diff --git a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
index be6a3c2..9de945e 100644
--- a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
+++ b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
@@ -153,7 +153,7 @@
             result = \
                 handle_results.check_log_for_errors(dataset['log_file_path'])
             if not result:
-                failed = true
+                failed = True
                 break
 
         if failed:
@@ -282,7 +282,7 @@
 
     def _send_work_data(self):
         """ Send the WORK DATA in json format for job """
-        self.log.debug("Send the work data response: %s" % 
+        self.log.debug("Send the work data response: %s" %
                        json.dumps(self._get_work_data()))
         self.job.sendWorkData(json.dumps(self._get_work_data()))