def invoke_hook_cleanup(self):
    "invoke task hooks for just before the spout/bolt's cleanup method"
    for task_hook in self.task_hooks:
        task_hook.clean_up()
invoke task hooks for just before the spout/bolt's cleanup method
def invoke_hook_cleanup(self):
    
    for task_hook in self.task_hooks:
        task_hook.clean_up()