Method new

flow-rs/src/loader/python/node.rs:43–75

(
        instance_name: String,
        args: &toml::value::Table,
        params: &RegistryNodeParams,
    )

impl PyNode {
    pub fn new(
        instance_name: String,
        args: &toml::value::Table,
        params: &RegistryNodeParams,
    ) -> PyNode {
        let mut inputs = HashMap::new();
        let mut outputs = HashMap::new();
        for port in &params.inputs {
            let (k, v) = parse(port);
            inputs.insert(k, v);
        }
        for port in &params.outputs {
            let (k, v) = parse(port);
            outputs.insert(k, v);
        }
        let imp = Python::with_gil(|py| -> _ {
            let pyargs = toml2dict(py, args).expect("convert toml to python dict fault");
            match params.code.call1(py, (instance_name.as_str(), pyargs)) {
                Err(err) => {
                    err.print(py);
                    panic!("parse python code fault");
                }
                Ok(ret) => ret,
            }
        });
        PyNode {
            inputs,
            outputs,
            imp,
            name: params.name.clone(),
            exclusive: params.exclusive,
        }
    }

    async fn initialize(&mut self, res: ResourceCollection) {
        Python::with_gil(|py| -> PyResult<()> {