Method load_from_file

flow-rs/src/loader/python/mod.rs:192–225

(
        &self,
        local_key: u64,
        module_path: Option<&Path>,
        plugin_path: &Path,
    )

        Ok(plugins)
    }
    fn load_from_file(
        &self,
        local_key: u64,
        module_path: Option<&Path>,
        plugin_path: &Path,
    ) -> Result<Vec<Box<dyn Plugin>>> {
        pyo3::prepare_freethreaded_python();
        let cur = std::env::current_dir()?;
        let module_path = module_path.unwrap_or(&cur);
        let module_name = path_to_module(module_path, plugin_path)?;

        Python::with_gil(|py| -> PyResult<_> {
            let module_path = module_path.display().to_string();
            let syspath: &PyList = py.import("sys")?.getattr("path")?.try_into()?;
            if !syspath
                .iter()
                .any(|path| module_path.as_str() == path.extract::<&str>().unwrap())
            {
                syspath.insert(0, module_path)?;
            }

            ONCE_REGISTER.call_once(|| {
                let module = py.import("megflow").expect("module megflow not found");
                utils::utils_register(module).expect("python utility functions register fault");
                envelope::envelope_register(module).expect("python envelope register fault");
            });

            py.import(module_name.as_str())?;

            Ok(())
        })?;

        self.load_from_scope(local_key)
    }
}

crate::submit!(