(^i .ddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z erddlZdd lmZdd lmZne d Ze d Ze d Zej(eZdZ d ddZe ddddd ddZy)) annotations)ThreadPoolExecutor) TYPE_CHECKING)logging)experimental_func) _LazyImport) BaseStorageN)servicer) api_pb2_grpcgrpczoptuna.storages._grpc.servicerz1optuna.storages._grpc.auto_generated.api_pb2_grpcz%Y-%m-%d %H:%M:%S.%fctj|xs td}tjt j |||j|d||S)N ) max_workers:)r serverrr $add_StorageServiceServicer_to_server grpc_servicerOptunaStorageProxyServiceadd_insecure_portstoragehostport thread_poolrs ]/var/www/html/hubwallet-dev/venv/lib/python3.12/site-packages/optuna/storages/_grpc/server.py make_serverrs[[[J(:r(J KF55//8& vQtf-. Mz4.2.0 localhosti2)rrrct||||}|jtjd|d|tjd|j y)aRun a gRPC server for the given storage URL, host, and port. Example: Run this server with the following way: .. code:: from optuna.storages import run_grpc_proxy_server from optuna.storages import get_storage storage = get_storage("mysql+pymysql://:@/[?]") run_grpc_proxy_server(storage, host="localhost", port=13000) Please refer to the client class :class:`~optuna.storages.GrpcStorageProxy` for the client usage. Please use :func:`~optuna.storages.get_storage` instead of :class:`~optuna.storages.RDBStorage` since ``RDBStorage`` by itself does not use cache in process and it may cause significant slowdown. Args: storage: A storage object to proxy. host: Hostname to listen on. port: Port to listen on. thread_pool: Thread pool to use for the server. If :obj:`None`, a default thread pool with 10 workers will be used. .. warning:: Currently, gRPC storage proxy does not support the :class:`~optuna.storages.JournalStorage`. This issue is tracked in https://github.com/optuna/optuna/issues/6084. Please use :class:`~optuna.storages.RDBStorage` instead. zServer started at rz Listening...N)rstart_loggerinfowait_for_terminationrs rrun_grpc_proxy_serverr$&sPT$k :F LLN LL%dV1TF34 LL  !r)N) rr rstrrintrThreadPoolExecutor | Nonereturnz grpc.Server) rr rr%rr&rr'r(None) __future__rconcurrent.futuresrtypingroptunaroptuna._experimentalroptuna._importsroptuna.storagesr r optuna.storages._grpcr r$optuna.storages._grpc.auto_generatedr get_logger__name__r!DATETIME_FORMATrr$rrr7s"1 2''?A v D @AMRSL '  X &(Z^  #+.=V7-1 -" -" -"  -" + -"  -"-"r