Method add_edges

raphtory-graphql/src/python/client/remote_graph.rs:148–213

(&self, updates: Vec<PyEdgeAddition>)

    ///     None:
    #[pyo3(signature = (updates))]
    pub fn add_edges(&self, updates: Vec<PyEdgeAddition>) -> Result<(), ClientError> {
        let template = r#"
                {
                updateGraph(path: "{{ path }}") {
                    addEdges(
                        edges: [
                            {% for edge in edges %}
                            {
                                src: "{{ edge.src }}"
                                dst: "{{ edge.dst }}"
                                {% if edge.layer%}, layer: "{{ edge.layer }}"{% endif %}
                                {% if edge.updates%},
                                updates: [
                                    {% for tprop in edge.updates %}
                                    {
                                        time: {{ tprop.time[0] }},
                                        {% if tprop.properties%}
                                        properties: [
                                            {% for prop in tprop.properties%}
                                            {
                                                key: "{{ prop.key }}",
                                                value:{{prop.value | safe}}
                                            }
                                            {% if not loop.last %},{% endif %}
                                            {% endfor %}
                                        ]
                                        {% endif %}
                                    }
                                    {% if not loop.last %},{% endif %}
                                    {% endfor %}
                                ]
                                {% endif %}
                                {% if edge.metadata%},
                                metadata: [
                                    {% for cprop in edge.metadata %}
                                    {
                                        key: "{{ cprop.key }}",
                                        value:{{ cprop.value }}
                                    }
                                    {% if not loop.last %},{% endif %}
                                    {% endfor %}
                                ]
                                {% endif %}
                            }
                            {% if not loop.last %},{% endif %}
                            {% endfor %}
                        ]
                    )
                }
            }
        "#;

        let query_context = context! {
            path => self.graph.path.clone(),
            edges => updates,
        };

        let query = build_query(template, query_context)?;