Method load_node_metadata

raphtory/src/python/graph/graph.rs:990–1068

(
        &self,
        data: &Bound<PyAny>,
        id: &str,
        node_type: Option<&str>,
        node_type_col: Option<&str>,
        metadata: Option<Vec<PyBackedStr>>,
        shared_metadat

        signature = (data, id, node_type = None, node_type_col = None, metadata = None, shared_metadata = None, schema = None, csv_options = None)
    )]
    fn load_node_metadata(
        &self,
        data: &Bound<PyAny>,
        id: &str,
        node_type: Option<&str>,
        node_type_col: Option<&str>,
        metadata: Option<Vec<PyBackedStr>>,
        shared_metadata: Option<HashMap<String, Prop>>,
        schema: Option<Bound<PyAny>>,
        csv_options: Option<CsvReadOptions>,
    ) -> Result<(), GraphError> {
        let metadata = convert_py_prop_args(metadata.as_deref()).unwrap_or_default();
        let column_schema = convert_py_schema(schema)?;
        if data.hasattr("__arrow_c_stream__")? {
            load_node_metadata_from_arrow_c_stream(
                &self.graph,
                data,
                id,
                node_type,
                node_type_col,
                &metadata,
                shared_metadata.as_ref(),
                column_schema,
            )
        } else if let Ok(path) = data.extract::<PathBuf>() {
            // extracting PathBuf handles Strings too
            let is_parquet = is_parquet_path(&path)?;
            let is_csv = is_csv_path(&path)?;

            // fail before loading anything at all to avoid loading partial data
            if !is_csv && csv_options.is_some() {
                return Err(GraphError::from(PyValueError::new_err(format!(
                    "CSV options were passed but no CSV files were detected at {}.",
                    path.display()
                ))));
            }

            // wrap in Arc to avoid cloning the entire schema for Parquet, CSV, and inner loops in CSV path
            let arced_schema = column_schema.map(Arc::new);

            // if-if instead of if-else to support directories with mixed parquet and CSV files
            if is_parquet {
                load_node_metadata_from_parquet(
                    &self.graph,
                    path.as_path(),
                    id,
                    node_type,
                    node_type_col,
                    None,
                    None,
                    &metadata,
                    shared_metadata.as_ref(),
                    None,
                    None,
                    None,
                    arced_schema.clone(),
                )?;
            }