def error_handling(self, task, msg):

        if self.ent_id :
            return notify_error(task=task, msg=msg, graph_id=self.ent_id)