Method load_from_scope

flow-rs/src/loader/python/mod.rs:141–191

(&self, local_key: u64)

impl Loader for PythonLoader {
    fn load_from_scope(&self, local_key: u64) -> Result<Vec<Box<dyn Plugin>>> {
        pyo3::prepare_freethreaded_python();
        let mut plugins = vec![];
        Python::with_gil(|py| -> PyResult<()> {
            let plugins_param: HashMap<String, Vec<&PyDict>> = py
                .import("megflow")?
                .getattr("collect")?
                .call0()?
                .extract()?;
            for plugin_param in &plugins_param["nodes"] {
                let name: String = plugin_param.get_item("name").expect(ERR_MSG).extract()?;
                let inputs: Vec<String> =
                    plugin_param.get_item("inputs").expect(ERR_MSG).extract()?;
                let outputs: Vec<String> =
                    plugin_param.get_item("outputs").expect(ERR_MSG).extract()?;
                let code: PyObject = plugin_param.get_item("code").expect(ERR_MSG).extract()?;
                let exclusive: bool = plugin_param
                    .get_item("exclusive")
                    .expect(ERR_MSG)
                    .extract()?;
                plugins.push(
                    NodePlugin::new(
                        local_key,
                        RegistryNodeParams {
                            name,
                            code,
                            inputs,
                            outputs,
                            exclusive,
                        },
                    )
                    .boxed(),
                );
            }
            for plugin_param in &plugins_param["resources"] {
                let name: String = plugin_param.get_item("name").expect(ERR_MSG).extract()?;
                let code: PyObject = plugin_param.get_item("code").expect(ERR_MSG).extract()?;
                plugins.push(
                    ResourcePlugin {
                        local_key,
                        name,
                        res: code,
                    }
                    .boxed(),
                )
            }
            Ok(())
        })?;

        Ok(plugins)
    }
    fn load_from_file(
        &self,
        local_key: u64,