async def _process_regular_entity(
        self,
        entity_definition_id,
        entity_definition,
        source_node_id,
        destination_node_ids,
        nodes,
        edges,
    ):
        """Process a regular entity and create necessary nodes and edges."""
        entity_node_id = uuid4()
        nodes.append(
            DagNodeCreate(
                id=entity_node_id,
                type=NodeType.entity,
                name=entity_definition.name,
                entity_definition_id=entity_definition_id,
            )
        )

        # Connect source to entity
        edges.append(
            DagEdgeCreate(
                from_node_id=source_node_id,
                to_node_id=entity_node_id,
            )
        )

        # Connect entity to all destination nodes
        for dest_node_id in destination_node_ids:
            edges.append(
                DagEdgeCreate(
                    from_node_id=entity_node_id,
                    to_node_id=dest_node_id,
                )
            )
Process a regular entity and create necessary nodes and edges.
backend/airweave/core/dag_service.py