diff --git a/src/safeds_runner/server/module_manager.py b/src/safeds_runner/server/module_manager.py index 4b0d9cd..863ef00 100644 --- a/src/safeds_runner/server/module_manager.py +++ b/src/safeds_runner/server/module_manager.py @@ -64,7 +64,10 @@ def _add_possible_packages_for_package_path(self, package_path: str) -> None: self.allowed_packages.add(package_path) def find_spec( - self, fullname: str, path: typing.Sequence[str] | None = None, target: types.ModuleType | None = None, + self, + fullname: str, + path: typing.Sequence[str] | None = None, + target: types.ModuleType | None = None, ) -> ModuleSpec | None: """ Find a module which may be registered in the code dictionary. @@ -77,7 +80,8 @@ def find_spec( logging.debug("Find Spec: %s %s %s", fullname, path, target) if fullname in self.allowed_packages: parent_package = importlib.util.spec_from_loader( - fullname, loader=InMemoryLoader(b"", fullname.replace(".", "/")), + fullname, + loader=InMemoryLoader(b"", fullname.replace(".", "/")), ) if parent_package is None: return None @@ -101,7 +105,8 @@ def find_spec( return importlib.util.spec_from_loader( fullname, loader=InMemoryLoader( - self.code[parent_package_path][submodule_name].encode("utf-8"), fullname.replace(".", "/"), + self.code[parent_package_path][submodule_name].encode("utf-8"), + fullname.replace(".", "/"), ), origin=parent_package_path, ) diff --git a/src/safeds_runner/server/pipeline_manager.py b/src/safeds_runner/server/pipeline_manager.py index f062ed5..117c7f2 100644 --- a/src/safeds_runner/server/pipeline_manager.py +++ b/src/safeds_runner/server/pipeline_manager.py @@ -152,7 +152,11 @@ def get_backtrace_info(error: BaseException) -> list[dict[str, typing.Any]]: def execute_pipeline( - code: dict[str, dict[str, str]], sdspackage: str, sdsmodule: str, sdspipeline: str, exec_id: str, + code: dict[str, dict[str, str]], + sdspackage: str, + sdsmodule: str, + sdspipeline: str, + exec_id: str, ) -> None: """ Run a Safe-DS pipeline. @@ -167,7 +171,13 @@ def execute_pipeline( if exec_id not in global_placeholder_map: global_placeholder_map[exec_id] = multiprocessing_manager.dict() process = PipelineProcess( - code, sdspackage, sdsmodule, sdspipeline, exec_id, global_messages_queue, global_placeholder_map[exec_id], + code, + sdspackage, + sdsmodule, + sdspipeline, + exec_id, + global_messages_queue, + global_placeholder_map[exec_id], ) process.execute()