def invoke_hook_prepare(self):
for task_hook in self.task_hooks:<EOL><INDENT>task_hook.prepare(self.get_cluster_config(), self)<EOL><DEDENT>
invoke task hooks for after the spout/bolt's initialize() method