(base) orion@skynet:~/Documents/SD/dalle-flow$ jina flow --uses flow.yml --quiet-error MMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMWWWMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MMMMMMMMMMMMMMMMMMMMMMMMMMMMMWNNNNNNNWMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MMMMMMMMMMMMMMMMMMMMMMMMMMMMMNNNNNNNNNMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MMMMMMMMMMMMMMMMMMMMMMMMMMMMMWNNNNNNNNMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMWNNNWWMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MMMMMMMMMMMMWxxxxxxxxxOMMMMMNxxxxxxxxx0MMMMMKddddddxkKWMMMMMMMMMMMMXOxdddxONMMMM MMMMMMMMMMMMXllllllllldMMMMM0lllllllllxMMMMMOllllllllllo0MMMMMMMM0olllllllllo0MM MMMMMMMMMMMMXllllllllldMMMMM0lllllllllxMMMMMOlllllllllllloWMMMMMdllllllllllllldM MMMMMMMMMMMMXllllllllldMMMMM0lllllllllxMMMMMOllllllllllllloMMMM0lllllllllllllllK MMMMMMMMMMMMKllllllllldMMMMM0lllllllllxMMMMMOllllllllllllllKMMM0lllllllllllllllO MMMMMMMMMMMMKllllllllldMMMMM0lllllllllxMMMMMOllllllllllllll0MMMMollllllllllllllO MWOkkkkk0MMMKlllllllllkMMMMM0lllllllllxMMMMMOllllllllllllll0MMMMMxlllllllllllllO NkkkkkkkkkMMKlllllllloMMMMMM0lllllllllxMMMMMOllllllllllllll0MMMMMMWOdolllllllllO KkkkkkkkkkNMKllllllldMMMMMMMMWWWWWWWWWMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MOkkkkkkk0MMKllllldXMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM MMWX00KXMMMMXxk0XMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMMM /usr/local/bin/jina flow --uses flow.yml --quiet-error ╭──────────────────┬──────────────────────────────────╮ │ Argument │ Value │ ├──────────────────┼──────────────────────────────────┤ │ cli │ flow │ │ env │ None │ │ inspect │ COLLECT │ │ log-config │ default │ │ name │ None │ │ optout-telemetry │ False │ │ quiet │ False │ │ quiet-error │ True │ │ uses │ flow.yml │ │ workspace │ None │ │ workspace-id │ 0e1772c645234b60a8246624fdfc1372 │ ╰──────────────────┴──────────────────────────────────╯ UserWarning: ignored unknown argument: ['--needs']. (raised from /usr/local/lib/python3.10/dist-packages/jina/helper.py:785) CRITI… dalle/rep-0@52867 can not load the executor from executors/dalle/config.yml [08/25/22 20:54:37] ⠋ Waiting ... ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 0/0 -:--:--CRITI… diffusion/rep-0@52868 can not load the executor from executors/glid3/config.yml [08/25/22 20:54:37] CRITI… upscaler/rep-0@52869 can not load the executor from executors/swinir/config.yml [08/25/22 20:54:37] DEBUG gateway/rep-0@52871 adding connection for deployment dalle/heads/0 to grpc://0.0.0.0:58870 [08/25/22 20:54:37] DEBUG store/rep-0@52870 is successfully loaded! [08/25/22 20:54:37] DEBUG gateway/rep-0@52871 adding connection for deployment clip_encoder/heads/0 to grpcs://demo-cas.jina.ai:2096 DEBUG gateway/rep-0@52871 adding connection for deployment diffusion/heads/0 to grpc://0.0.0.0:59650 DEBUG store/rep-0@52870 start listening on 0.0.0.0:60093 DEBUG gateway/rep-0@52871 adding connection for deployment rerank/heads/0 to grpcs://demo-cas.jina.ai:2096 DEBUG gateway/rep-0@52871 adding connection for deployment upscaler/heads/0 to grpc://0.0.0.0:58352 DEBUG gateway/rep-0@52871 adding connection for deployment store/heads/0 to grpc://0.0.0.0:60093 DEBUG gateway/rep-0@52871 start server bound to 0.0.0.0:51005 DEBUG store/rep-0@52842 ready and listening [08/25/22 20:54:37] DEBUG gateway/rep-0@52842 ready and listening [08/25/22 20:54:37] ⠙ Waiting dalle diffusion upscaler store gateway summary... ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 0/6 0:00:00ERROR dalle/rep-0@52867 ImportError('can not import module from [08/25/22 20:54:37] /home/orion/Documents/SD/dalle-flow/executors/dalle/executor/__init__.py') during initialization add "--quiet-error" to suppress the exception details ╭────────────────────────────── Traceback (most recent call last) ──────────────────────────────╮ │ /usr/local/lib/python3.10/dist-packages/jina/importer.py:128 in _path_import │ │ │ │ 125 │ │ spec = importlib.util.spec_from_file_location(spec_name, absolute_path) │ │ 126 │ │ module = importlib.util.module_from_spec(spec) │ │ 127 │ │ sys.modules[spec_name] = module │ │ ❱ 128 │ │ spec.loader.exec_module(module) │ │ 129 │ except Exception as ex: │ │ 130 │ │ raise ImportError(f'can not import module from {absolute_path}') from ex │ │ 131 │ │ :883 in exec_module │ │ :241 in _call_with_frames_removed │ │ │ │ /home/orion/Documents/SD/dalle-flow/executors/dalle/executor/__init__.py:1 in │ │ │ │ ❱ 1 from .dalle import DalleGenerator │ │ 2 │ │ │ │ /home/orion/Documents/SD/dalle-flow/executors/dalle/executor/dalle.py:7 in │ │ │ │ 4 │ │ 5 from jina import Executor, requests, DocumentArray, Document │ │ 6 │ │ ❱ 7 from . import dm_helper │ │ 8 │ │ 9 │ │ 10 class DalleGenerator(Executor): │ │ │ │ /home/orion/Documents/SD/dalle-flow/executors/dalle/executor/dm_helper.py:5 in │ │ │ │ 2 import time │ │ 3 from functools import partial │ │ 4 │ │ ❱ 5 import jax │ │ 6 import jax.numpy as jnp │ │ 7 import numpy as np │ │ 8 import wandb │ ╰───────────────────────────────────────────────────────────────────────────────────────────────╯ ModuleNotFoundError: No module named 'jax' The above exception was the direct cause of the following exception: ╭────────────────────────────── Traceback (most recent call last) ──────────────────────────────╮ │ /usr/local/lib/python3.10/dist-packages/jina/orchestrate/pods/__init__.py:74 in run │ │ │ │ 71 │ │ │ 72 │ try: │ │ 73 │ │ _set_envs() │ │ ❱ 74 │ │ runtime = runtime_cls( │ │ 75 │ │ │ args=args, │ │ 76 │ │ ) │ │ 77 │ except Exception as ex: │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/worker/__init__.py:31 in __init__ │ │ │ │ 28 │ │ :param kwargs: keyword args │ │ 29 │ │ """ │ │ 30 │ │ self._health_servicer = health.HealthServicer(experimental_non_blocking=True) │ │ ❱ 31 │ │ super().__init__(args, **kwargs) │ │ 32 │ │ │ 33 │ async def async_setup(self): │ │ 34 │ │ """ │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/asyncio.py:70 in __init__ │ │ │ │ 67 │ │ if not self.args.optout_telemetry and 'JINA_DISABLE_TELMETRY' not in os.environ │ │ 68 │ │ │ from jina.serve.helper import _telemetry_run_in_thread │ │ 69 │ │ │ _telemetry_run_in_thread(event=f'{self.__class__.__name__}.start') │ │ ❱ 70 │ │ self._loop.run_until_complete(self.async_setup()) │ │ 71 │ │ │ 72 │ def run_forever(self): │ │ 73 │ │ """ │ │ │ │ /usr/lib/python3.10/asyncio/base_events.py:646 in run_until_complete │ │ │ │ 643 │ │ if not future.done(): │ │ 644 │ │ │ raise RuntimeError('Event loop stopped before Future completed.') │ │ 645 │ │ │ │ ❱ 646 │ │ return future.result() │ │ 647 │ │ │ 648 │ def stop(self): │ │ 649 │ │ """Stop running the event loop. │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/worker/__init__.py:60 in │ │ async_setup │ │ │ │ 57 │ │ # Keep this initialization order │ │ 58 │ │ # otherwise readiness check is not valid │ │ 59 │ │ # The DataRequestHandler needs to be started BEFORE the grpc server │ │ ❱ 60 │ │ self._data_request_handler = DataRequestHandler( │ │ 61 │ │ │ self.args, self.logger, self.metrics_registry │ │ 62 │ │ ) │ │ 63 │ │ await self._async_setup_grpc_server() │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/request_handlers/data_request_ha… │ │ in __init__ │ │ │ │ 41 │ │ self.args.parallel = self.args.shards │ │ 42 │ │ self.logger = logger │ │ 43 │ │ self._is_closed = False │ │ ❱ 44 │ │ self._load_executor(metrics_registry) │ │ 45 │ │ self._init_monitoring(metrics_registry) │ │ 46 │ │ │ 47 │ def _init_monitoring(self, metrics_registry: Optional['CollectorRegistry'] = None): │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/request_handlers/data_request_ha… │ │ in _load_executor │ │ │ │ 79 │ │ :param metrics_registry: Optional prometheus metrics registry that will be │ │ passed to the executor so that it can expose metrics │ │ 80 │ │ """ │ │ 81 │ │ try: │ │ ❱ 82 │ │ │ self._executor: BaseExecutor = BaseExecutor.load_config( │ │ 83 │ │ │ │ self.args.uses, │ │ 84 │ │ │ │ uses_with=self.args.uses_with, │ │ 85 │ │ │ │ uses_metas=self.args.uses_metas, │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/__init__.py:730 in load_config │ │ │ │ 727 │ │ │ │ │ 728 │ │ │ if allow_py_modules: │ │ 729 │ │ │ │ _extra_search_paths = extra_search_paths or [] │ │ ❱ 730 │ │ │ │ load_py_modules( │ │ 731 │ │ │ │ │ no_tag_yml, │ │ 732 │ │ │ │ │ extra_search_paths=(_extra_search_paths + [os.path.dirname(s_path)] │ │ 733 │ │ │ │ │ if s_path │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/helper.py:274 in load_py_modules │ │ │ │ 271 │ _finditem(d) │ │ 272 │ if mod: │ │ 273 │ │ mod = [complete_path(m, extra_search_paths, raise_nonexist=False) for m in mod] │ │ ❱ 274 │ │ PathImporter.add_modules(*mod) │ │ 275 │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/importer.py:159 in add_modules │ │ │ │ 156 │ │ from jina.jaml.helper import complete_path │ │ 157 │ │ │ │ 158 │ │ for m in not_python_module_paths: │ │ ❱ 159 │ │ │ _path_import(complete_path(m)) │ │ 160 │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/importer.py:130 in _path_import │ │ │ │ 127 │ │ sys.modules[spec_name] = module │ │ 128 │ │ spec.loader.exec_module(module) │ │ 129 │ except Exception as ex: │ │ ❱ 130 │ │ raise ImportError(f'can not import module from {absolute_path}') from ex │ │ 131 │ │ 132 │ │ 133 class PathImporter: │ ╰───────────────────────────────────────────────────────────────────────────────────────────────╯ ImportError: can not import module from /home/orion/Documents/SD/dalle-flow/executors/dalle/executor/__init__.py DEBUG dalle/rep-0@52867 process terminated ERROR upscaler/rep-0@52869 ImportError('can not import module from [08/25/22 20:54:37] /home/orion/Documents/SD/dalle-flow/executors/swinir/executor.py') during initialization add "--quiet-error" to suppress the exception details ╭────────────────────────────── Traceback (most recent call last) ──────────────────────────────╮ │ /usr/local/lib/python3.10/dist-packages/jina/importer.py:128 in _path_import │ │ │ │ 125 │ │ spec = importlib.util.spec_from_file_location(spec_name, absolute_path) │ │ 126 │ │ module = importlib.util.module_from_spec(spec) │ │ 127 │ │ sys.modules[spec_name] = module │ │ ❱ 128 │ │ spec.loader.exec_module(module) │ │ 129 │ except Exception as ex: │ │ 130 │ │ raise ImportError(f'can not import module from {absolute_path}') from ex │ │ 131 │ │ :883 in exec_module │ │ :241 in _call_with_frames_removed │ │ │ │ /home/orion/Documents/SD/dalle-flow/executors/swinir/executor.py:8 in │ │ │ │ 5 │ │ 6 from jina import Executor, DocumentArray, Document, requests │ │ 7 │ │ ❱ 8 from dalle_flow_swin_ir.main_test_swinir import main as swin_ir_main, get_model │ │ 9 │ │ 10 class SwinIRUpscaler(Executor): │ │ 11 │ def __init__(self, swinir_path: str, **kwargs): │ ╰───────────────────────────────────────────────────────────────────────────────────────────────╯ ModuleNotFoundError: No module named 'dalle_flow_swin_ir' The above exception was the direct cause of the following exception: ╭────────────────────────────── Traceback (most recent call last) ──────────────────────────────╮ │ /usr/local/lib/python3.10/dist-packages/jina/orchestrate/pods/__init__.py:74 in run │ │ │ │ 71 │ │ │ 72 │ try: │ │ 73 │ │ _set_envs() │ │ ❱ 74 │ │ runtime = runtime_cls( │ │ 75 │ │ │ args=args, │ │ 76 │ │ ) │ │ 77 │ except Exception as ex: │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/worker/__init__.py:31 in __init__ │ │ │ │ 28 │ │ :param kwargs: keyword args │ │ 29 │ │ """ │ │ 30 │ │ self._health_servicer = health.HealthServicer(experimental_non_blocking=True) │ │ ❱ 31 │ │ super().__init__(args, **kwargs) │ │ 32 │ │ │ 33 │ async def async_setup(self): │ │ 34 │ │ """ │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/asyncio.py:70 in __init__ │ │ │ │ 67 │ │ if not self.args.optout_telemetry and 'JINA_DISABLE_TELMETRY' not in os.environ │ │ 68 │ │ │ from jina.serve.helper import _telemetry_run_in_thread │ │ 69 │ │ │ _telemetry_run_in_thread(event=f'{self.__class__.__name__}.start') │ │ ❱ 70 │ │ self._loop.run_until_complete(self.async_setup()) │ │ 71 │ │ │ 72 │ def run_forever(self): │ │ 73 │ │ """ │ │ │ │ /usr/lib/python3.10/asyncio/base_events.py:646 in run_until_complete │ │ │ │ 643 │ │ if not future.done(): │ │ 644 │ │ │ raise RuntimeError('Event loop stopped before Future completed.') │ │ 645 │ │ │ │ ❱ 646 │ │ return future.result() │ │ 647 │ │ │ 648 │ def stop(self): │ │ 649 │ │ """Stop running the event loop. │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/worker/__init__.py:60 in │ │ async_setup │ │ │ │ 57 │ │ # Keep this initialization order │ │ 58 │ │ # otherwise readiness check is not valid │ │ 59 │ │ # The DataRequestHandler needs to be started BEFORE the grpc server │ │ ❱ 60 │ │ self._data_request_handler = DataRequestHandler( │ │ 61 │ │ │ self.args, self.logger, self.metrics_registry │ │ 62 │ │ ) │ │ 63 │ │ await self._async_setup_grpc_server() │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/request_handlers/data_request_ha… │ │ in __init__ │ │ │ │ 41 │ │ self.args.parallel = self.args.shards │ │ 42 │ │ self.logger = logger │ │ 43 │ │ self._is_closed = False │ │ ❱ 44 │ │ self._load_executor(metrics_registry) │ │ 45 │ │ self._init_monitoring(metrics_registry) │ │ 46 │ │ │ 47 │ def _init_monitoring(self, metrics_registry: Optional['CollectorRegistry'] = None): │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/request_handlers/data_request_ha… │ │ in _load_executor │ │ │ │ 79 │ │ :param metrics_registry: Optional prometheus metrics registry that will be │ │ passed to the executor so that it can expose metrics │ │ 80 │ │ """ │ │ 81 │ │ try: │ │ ❱ 82 │ │ │ self._executor: BaseExecutor = BaseExecutor.load_config( │ │ 83 │ │ │ │ self.args.uses, │ │ 84 │ │ │ │ uses_with=self.args.uses_with, │ │ 85 │ │ │ │ uses_metas=self.args.uses_metas, │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/__init__.py:730 in load_config │ │ │ │ 727 │ │ │ │ │ 728 │ │ │ if allow_py_modules: │ │ 729 │ │ │ │ _extra_search_paths = extra_search_paths or [] │ │ ❱ 730 │ │ │ │ load_py_modules( │ │ 731 │ │ │ │ │ no_tag_yml, │ │ 732 │ │ │ │ │ extra_search_paths=(_extra_search_paths + [os.path.dirname(s_path)] │ │ 733 │ │ │ │ │ if s_path │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/helper.py:274 in load_py_modules │ │ │ │ 271 │ _finditem(d) │ │ 272 │ if mod: │ │ 273 │ │ mod = [complete_path(m, extra_search_paths, raise_nonexist=False) for m in mod] │ │ ❱ 274 │ │ PathImporter.add_modules(*mod) │ │ 275 │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/importer.py:159 in add_modules │ │ │ │ 156 │ │ from jina.jaml.helper import complete_path │ │ 157 │ │ │ │ 158 │ │ for m in not_python_module_paths: │ │ ❱ 159 │ │ │ _path_import(complete_path(m)) │ │ 160 │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/importer.py:130 in _path_import │ │ │ │ 127 │ │ sys.modules[spec_name] = module │ │ 128 │ │ spec.loader.exec_module(module) │ │ 129 │ except Exception as ex: │ │ ❱ 130 │ │ raise ImportError(f'can not import module from {absolute_path}') from ex │ │ 131 │ │ 132 │ │ 133 class PathImporter: │ ╰───────────────────────────────────────────────────────────────────────────────────────────────╯ ImportError: can not import module from /home/orion/Documents/SD/dalle-flow/executors/swinir/executor.py DEBUG upscaler/rep-0@52869 process terminated ERROR diffusion/rep-0@52868 ModuleNotFoundError("No module named 'dalle_flow_glid3'") during initialization add "--quiet-error" to suppress the exception details ╭────────────────────────────── Traceback (most recent call last) ──────────────────────────────╮ │ /usr/local/lib/python3.10/dist-packages/jina/orchestrate/pods/__init__.py:74 in run │ │ │ │ 71 │ │ │ 72 │ try: │ │ 73 │ │ _set_envs() │ │ ❱ 74 │ │ runtime = runtime_cls( │ │ 75 │ │ │ args=args, │ │ 76 │ │ ) │ │ 77 │ except Exception as ex: │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/worker/__init__.py:31 in __init__ │ │ │ │ 28 │ │ :param kwargs: keyword args │ │ 29 │ │ """ │ │ 30 │ │ self._health_servicer = health.HealthServicer(experimental_non_blocking=True) │ │ ❱ 31 │ │ super().__init__(args, **kwargs) │ │ 32 │ │ │ 33 │ async def async_setup(self): │ │ 34 │ │ """ │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/asyncio.py:70 in __init__ │ │ │ │ 67 │ │ if not self.args.optout_telemetry and 'JINA_DISABLE_TELMETRY' not in os.environ │ │ 68 │ │ │ from jina.serve.helper import _telemetry_run_in_thread │ │ 69 │ │ │ _telemetry_run_in_thread(event=f'{self.__class__.__name__}.start') │ │ ❱ 70 │ │ self._loop.run_until_complete(self.async_setup()) │ │ 71 │ │ │ 72 │ def run_forever(self): │ │ 73 │ │ """ │ │ │ │ /usr/lib/python3.10/asyncio/base_events.py:646 in run_until_complete │ │ │ │ 643 │ │ if not future.done(): │ │ 644 │ │ │ raise RuntimeError('Event loop stopped before Future completed.') │ │ 645 │ │ │ │ ❱ 646 │ │ return future.result() │ │ 647 │ │ │ 648 │ def stop(self): │ │ 649 │ │ """Stop running the event loop. │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/worker/__init__.py:60 in │ │ async_setup │ │ │ │ 57 │ │ # Keep this initialization order │ │ 58 │ │ # otherwise readiness check is not valid │ │ 59 │ │ # The DataRequestHandler needs to be started BEFORE the grpc server │ │ ❱ 60 │ │ self._data_request_handler = DataRequestHandler( │ │ 61 │ │ │ self.args, self.logger, self.metrics_registry │ │ 62 │ │ ) │ │ 63 │ │ await self._async_setup_grpc_server() │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/request_handlers/data_request_ha… │ │ in __init__ │ │ │ │ 41 │ │ self.args.parallel = self.args.shards │ │ 42 │ │ self.logger = logger │ │ 43 │ │ self._is_closed = False │ │ ❱ 44 │ │ self._load_executor(metrics_registry) │ │ 45 │ │ self._init_monitoring(metrics_registry) │ │ 46 │ │ │ 47 │ def _init_monitoring(self, metrics_registry: Optional['CollectorRegistry'] = None): │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/runtimes/request_handlers/data_request_ha… │ │ in _load_executor │ │ │ │ 79 │ │ :param metrics_registry: Optional prometheus metrics registry that will be │ │ passed to the executor so that it can expose metrics │ │ 80 │ │ """ │ │ 81 │ │ try: │ │ ❱ 82 │ │ │ self._executor: BaseExecutor = BaseExecutor.load_config( │ │ 83 │ │ │ │ self.args.uses, │ │ 84 │ │ │ │ uses_with=self.args.uses_with, │ │ 85 │ │ │ │ uses_metas=self.args.uses_metas, │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/__init__.py:760 in load_config │ │ │ │ 757 │ │ │ │ # revert yaml's tag and load again, this time with substitution │ │ 758 │ │ │ │ tag_yml = JAML.unescape(JAML.dump(no_tag_yml)) │ │ 759 │ │ │ # load into object, no more substitute │ │ ❱ 760 │ │ │ obj = JAML.load(tag_yml, substitute=False, runtime_args=runtime_args) │ │ 761 │ │ │ if not isinstance(obj, cls): │ │ 762 │ │ │ │ raise BadConfigSource( │ │ 763 │ │ │ │ │ f'Can not construct {cls} object from {source}. Source might be an │ │ invalid configuration.' │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/__init__.py:174 in load │ │ │ │ 171 │ │ :return: the Python object │ │ 172 │ │ │ │ 173 │ │ """ │ │ ❱ 174 │ │ r = yaml.load(stream, Loader=get_jina_loader_with_runtime(runtime_args)) │ │ 175 │ │ │ │ 176 │ │ if substitute: │ │ 177 │ │ │ r = JAML.expand_dict(r, context) │ │ │ │ /usr/lib/python3/dist-packages/yaml/__init__.py:114 in load │ │ │ │ 111 │ │ │ 112 │ loader = Loader(stream) │ │ 113 │ try: │ │ ❱ 114 │ │ return loader.get_single_data() │ │ 115 │ finally: │ │ 116 │ │ loader.dispose() │ │ 117 │ │ │ │ /usr/lib/python3/dist-packages/yaml/constructor.py:51 in get_single_data │ │ │ │ 48 │ │ # Ensure that the stream contains a single document and construct it. │ │ 49 │ │ node = self.get_single_node() │ │ 50 │ │ if node is not None: │ │ ❱ 51 │ │ │ return self.construct_document(node) │ │ 52 │ │ return None │ │ 53 │ │ │ 54 │ def construct_document(self, node): │ │ │ │ /usr/lib/python3/dist-packages/yaml/constructor.py:55 in construct_document │ │ │ │ 52 │ │ return None │ │ 53 │ │ │ 54 │ def construct_document(self, node): │ │ ❱ 55 │ │ data = self.construct_object(node) │ │ 56 │ │ while self.state_generators: │ │ 57 │ │ │ state_generators = self.state_generators │ │ 58 │ │ │ self.state_generators = [] │ │ │ │ /usr/lib/python3/dist-packages/yaml/constructor.py:100 in construct_object │ │ │ │ 97 │ │ │ │ elif isinstance(node, MappingNode): │ │ 98 │ │ │ │ │ constructor = self.__class__.construct_mapping │ │ 99 │ │ if tag_suffix is None: │ │ ❱ 100 │ │ │ data = constructor(self, node) │ │ 101 │ │ else: │ │ 102 │ │ │ data = constructor(self, tag_suffix, node) │ │ 103 │ │ if isinstance(data, types.GeneratorType): │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/__init__.py:582 in _from_yaml │ │ │ │ 579 │ │ data = constructor.construct_mapping(node, deep=True) │ │ 580 │ │ from jina.jaml.parsers import get_parser │ │ 581 │ │ │ │ ❱ 582 │ │ return get_parser(cls, version=data.get('version', None)).parse( │ │ 583 │ │ │ cls, data, runtime_args=constructor.runtime_args │ │ 584 │ │ ) │ │ 585 │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/jaml/parsers/executor/legacy.py:88 in parse │ │ │ │ 85 │ │ │ │ runtime_args=runtime_args, │ │ 86 │ │ │ ) │ │ 87 │ │ else: │ │ ❱ 88 │ │ │ obj = cls( │ │ 89 │ │ │ │ **data.get('with', {}), │ │ 90 │ │ │ │ metas=data.get('metas', {}), │ │ 91 │ │ │ │ requests=data.get('requests', {}), │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/executors/decorators.py:117 in arg_wrapper │ │ │ │ 114 │ │ │ │ │ file_lock = filelock.FileLock(lock_file, timeout=-1) │ │ 115 │ │ │ │ │ │ 116 │ │ │ │ with file_lock: │ │ ❱ 117 │ │ │ │ │ f = func(self, *args, **kwargs) │ │ 118 │ │ │ │ return f │ │ 119 │ │ │ else: │ │ 120 │ │ │ │ return func(self, *args, **kwargs) │ │ │ │ /usr/local/lib/python3.10/dist-packages/jina/serve/executors/decorators.py:76 in arg_wrapper │ │ │ │ 73 │ │ else: │ │ 74 │ │ │ self._init_kwargs_dict = tmp │ │ 75 │ │ convert_tuple_to_list(self._init_kwargs_dict) │ │ ❱ 76 │ │ f = func(self, *args, **kwargs) │ │ 77 │ │ return f │ │ 78 │ │ │ 79 │ return arg_wrapper │ │ │ │ /home/orion/Documents/SD/dalle-flow/executors/glid3/executor.py:18 in __init__ │ │ │ │ 15 │ │ os.environ['GLID_MODEL_PATH'] = glid3_path │ │ 16 │ │ os.environ['GLID3_STEPS'] = str(steps) │ │ 17 │ │ self.diffusion_steps = steps │ │ ❱ 18 │ │ from dalle_flow_glid3.model import static_args │ │ 19 │ │ from dalle_flow_glid3.blank_encoding import generate_blank_embeddings │ │ 20 │ │ │ │ 21 │ │ assert static_args │ ╰───────────────────────────────────────────────────────────────────────────────────────────────╯ ModuleNotFoundError: No module named 'dalle_flow_glid3' DEBUG diffusion/rep-0@52868 process terminated DEBUG upscaler/rep-0@52842 waiting for ready or shutdown signal from runtime [08/25/22 20:54:37] DEBUG upscaler/rep-0@52842 shutdown is is already set. Runtime will end gracefully on its own DEBUG upscaler/rep-0@52842 terminating the runtime process DEBUG diffusion/rep-0@52842 waiting for ready or shutdown signal from runtime [08/25/22 20:54:37] DEBUG upscaler/rep-0@52842 runtime process properly terminated DEBUG dalle/rep-0@52842 waiting for ready or shutdown signal from runtime [08/25/22 20:54:37] DEBUG diffusion/rep-0@52842 shutdown is is already set. Runtime will end gracefully on its own DEBUG dalle/rep-0@52842 shutdown is is already set. Runtime will end gracefully on its own DEBUG upscaler/rep-0@52842 terminated DEBUG diffusion/rep-0@52842 terminating the runtime process DEBUG upscaler/rep-0@52842 joining the process DEBUG dalle/rep-0@52842 terminating the runtime process DEBUG diffusion/rep-0@52842 runtime process properly terminated DEBUG upscaler/rep-0@52842 successfully joined the process DEBUG dalle/rep-0@52842 runtime process properly terminated DEBUG diffusion/rep-0@52842 terminated DEBUG dalle/rep-0@52842 terminated DEBUG diffusion/rep-0@52842 joining the process DEBUG dalle/rep-0@52842 joining the process DEBUG diffusion/rep-0@52842 successfully joined the process DEBUG dalle/rep-0@52842 successfully joined the process ERROR Flow@52842 Flow is aborted due to ['dalle', 'diffusion', 'upscaler'] can not be started. [08/25/22 20:54:42] DEBUG gateway/rep-0@52842 waiting for ready or shutdown signal from runtime [08/25/22 20:54:42] DEBUG gateway/rep-0@52842 terminate DEBUG gateway/rep-0@52842 terminating the runtime process DEBUG gateway/rep-0@52842 runtime process properly terminated ⠼ Waiting summary... ━━━━━━━━━━━━━╺━━━━━━━━━━━━━━━━━━━━━━━━━━ 2/6 0:00:05DEBUG gateway/rep-0@52871 process terminated [08/25/22 20:54:42] DEBUG gateway/rep-0@52842 terminated DEBUG gateway/rep-0@52842 joining the process DEBUG gateway/rep-0@52842 successfully joined the process DEBUG store/rep-0@52842 waiting for ready or shutdown signal from runtime [08/25/22 20:54:42] DEBUG store/rep-0@52842 terminate DEBUG store/rep-0@52842 terminating the runtime process DEBUG store/rep-0@52842 runtime process properly terminated ⠴ Waiting ... ━━━━━━━━━━━━━━━━━━━━╺━━━━━━━━━━━━━━━━━━━ 3/6 0:00:05DEBUG store/rep-0@52870 cancel WorkerRuntime [08/25/22 20:54:42] DEBUG store/rep-0@52870 stopped GRPC Server DEBUG store/rep-0@52870 cancel WorkerRuntime DEBUG store/rep-0@52870 stopped GRPC Server DEBUG store/rep-0@52870 process terminated [08/25/22 20:54:42] DEBUG store/rep-0@52842 terminated DEBUG store/rep-0@52842 joining the process DEBUG store/rep-0@52842 successfully joined the process DeprecationWarning: the imp module is deprecated in favour of importlib and slated for removal in Python 3.12; see the module's documentation for alternative uses (raised from /usr/lib/python3/dist-packages/apport/report.py:13) Traceback (most recent call last): File "/usr/local/bin/jina", line 8, in sys.exit(main()) File "/usr/local/lib/python3.10/dist-packages/jina_cli/__init__.py", line 143, in main getattr(api, args.cli.replace('-', '_'))(args) File "/usr/local/lib/python3.10/dist-packages/jina_cli/api.py", line 162, in flow with f: File "/usr/local/lib/python3.10/dist-packages/jina/orchestrate/flow/base.py", line 1413, in __enter__ return self.start() File "/usr/local/lib/python3.10/dist-packages/jina/orchestrate/flow/builder.py", line 33, in arg_wrapper return func(self, *args, **kwargs) File "/usr/local/lib/python3.10/dist-packages/jina/orchestrate/flow/base.py", line 1469, in start self._wait_until_all_ready() File "/usr/local/lib/python3.10/dist-packages/jina/orchestrate/flow/base.py", line 1571, in _wait_until_all_ready raise RuntimeFailToStart jina.excepts.RuntimeFailToStart (base) orion@skynet:~/Documents/SD/dalle-flow$