Merge branch 'master' into Issue-#1

modules/FirehoseJob.py

@@ -197,13 +197,17 @@ def __init__(self, creds = [], neo4j_creds = None, TWEETS_PER_PROCESS=100, TWEET
         self.__file_names = []
 
     def __del__(self):
+
         logger.debug('__del__')
         self.destroy()        
 
+
     def destroy(self, job_name='generic_job'):
         logger.debug('flush before destroying..')
         self.flush(job_name)
+
         logger.debug('destroy', self.writers.keys())        
+
         for k in self.writers.keys():
             if not (self.writers[k] is None):
                 logger.debug('Closing parquet writer %s' % k)
@@ -216,8 +220,10 @@ def destroy(self, job_name='generic_job'):
                 time.sleep(1)
                 logger.debug('... Safely closed %s' % k)
             else:
+
                 logger.debug('Nothing to close for writer %s' % k)
 
+
     ###################
 
     def get_creation_time(self, id):