def METHOD_NAME(self, pipeline_template, pipeline_tree):
    new_nodes = get_all_nodes(pipeline_tree)
    nodes_info = []
    for node_id, node in new_nodes.items():
        nodes_info.append(
            self.model(
                node_id=node_id,
                node_type=node[PWE.type],
                template_id=pipeline_template.template_id,
                version=pipeline_template.version,
            )
        )
    self.model.objects.bulk_create(nodes_info)
    # send signal
    nodes_objs = self.model.objects.filter(
        template_id=pipeline_template.template_id, version=pipeline_template.version
    )
    node_in_template_post_save.send(sender=self.model, nodes_objs=nodes_objs, nodes_info=new_nodes)