def wait_for_current_tasks(self):
logger.info("<STR_LIT>")<EOL>for task_id in self.tasks:<EOL><INDENT>fut = self.tasks[task_id]['<STR_LIT>']<EOL>if not fut.done():<EOL><INDENT>logger.debug("<STR_LIT>".format(task_id))<EOL>fut.exception()<EOL><DEDENT><DEDENT>logger.info("<STR_LIT>")<EOL>
Waits for all tasks in the task list to be completed, by waiting for their
        AppFuture to be completed. This method will not necessarily wait for any tasks
        added after cleanup has started (such as data stageout?)