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