o niB@sddlmZddlZddlZddlmZddlmZddlm Z ddlm Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZmZddlmZGdddeZGdddeZGdddeZ d!ddZ!d"ddZ"d!ddZ#Gd ddZ$dS)#) annotationsN)Callable)wandb_internal_pb2)wandb_server_pb2)wandb_settings_pb2)wandb_settings) InterfaceBase) InterfaceSock) service_token) ExitHooks)Mailbox) SockClientSockClientTimeoutError)servicec@eZdZdZdS)WandbServiceNotOwnedErrorzARaised when the current process does not own the service process.N__name__ __module__ __qualname____doc__rr^/home/ubuntu/SoloSpeech/.venv/lib/python3.10/site-packages/wandb/sdk/lib/service_connection.pyrrc@r)WandbServiceConnectionErrorz4Raised on failure to connect to the service process.Nrrrrrrrrc@r)WandbAttachFailedErrorz#Raised if attaching to a run fails.Nrrrrrrrrsettingswandb_settings.SettingsreturnServiceConnectioncCst}|r|St|S)z>Connects to the service process, starting one up if necessary.) _try_connect_to_existing_service_start_and_connect_service)rconnrrrconnect_to_service sr#ServiceConnection | Nonec Csdt}|sdS|jdksJt}z||jWnty+}ztd|d}~wwt|ddS)z2Attemps to connect to an existing service process.N localhostz&Failed to connect to internal service.)clientproc) r get_service_tokenhostr connectport Exceptionrr)tokenr&errrr +s  r cst|}||j}|sJt}||tjt dd|dt  fddt ||fdddt S) zStarts a service process and returns a connection to it. An atexit hook is registered to tear down the service process and wait for it to complete. The hook does not run in processes started using the multiprocessing module. tcpr%) parent_pid transportr)r+csjdSN)teardown exit_coder)r"hooksrrteardown_atexit\sz3_start_and_connect_service..teardown_atexitcs tSr2)atexit unregisterr)r6rrbs z,_start_and_connect_service..)r&r'cleanup)r_Servicestart sock_portr r*r set_service_tokenosgetpidr hookrr7register)rr'r+r&r)r"r5r6rr!As,    r!c@sdeZdZdZ d'd(d d Zd)ddZd*ddZd+ddZd,ddZd-dd Z d+d!d"Z d.d%d&Z dS)/rz1A connection to the W&B internal service process.Nr&r r'service._Service | Noner:Callable[[], None] | NonecCs||_||_d|_||_dS)aReturns a new ServiceConnection. Args: client: A socket that's connected to the service. proc: The service process if we own it, or None otherwise. cleanup: A callback to run on teardown before doing anything. FN)_client_proc _torn_down_cleanup)selfr&r'r:rrr__init__ms  zServiceConnection.__init__mailboxr rrcCs t|j|S)z8Returns an interface for communicating with the service.)r rE)rIrKrrrmake_interfaces z ServiceConnection.make_interfacerecord pb.RecordNonecCs|j|dS)zSends data to the service.N)rEsend_record_publish)rIrMrrr send_recordszServiceConnection.send_recordrwandb_settings_pb2.Settingsrun_idstrcC.t}|j|||j_|jj|ddS)z%Sends an init request to the service.) inform_initN)spbServerInformInitRequestrCopyFrom_info stream_idrEsendrIrrSrequestrrrrV zServiceConnection.inform_initcCs"t}||j_|jj|ddS)z'Sends an finish request to the service.) inform_finishN)rWServerInformFinishRequestrZr[rEr\)rIrSr^rrrr`szServiceConnection.inform_finish attach_idcCs@t}||j_z |jj|d}|jjWStyt dw)zwSends an attach request to the service. Raises a WandbAttachFailedError if attaching is not possible. ) inform_attachzCould not attach because the run does not belong to the current service process, or because the service process is busy (unlikely).) rWServerInformAttachRequestrZr[rE send_and_recvinform_attach_responserrr)rIrbr^responserrrrcs  zServiceConnection.inform_attachcCrU)z%Sends a start request to the service.) inform_startN)rWServerInformStartRequestrrYrZr[rEr\r]rrrrhr_zServiceConnection.inform_startr4intcCsT|jstd|jr Jd|_|jr|t|jjtj |dd|j S)a/Shuts down the service process and returns its exit code. This may only be called once. Returns: The exit code of the service process. Raises: WandbServiceNotOwnedError: If the current process did not start the service process. z5Cannot tear down service started by different processT)r4)inform_teardown) rFrrGrHr clear_service_tokenrEr\rWServerInformTeardownRequestjoin)rIr4rrrr3s   zServiceConnection.teardownr2)r&r r'rCr:rD)rKr rr)rMrNrrO)rrRrSrTrrO)rSrTrrO)rbrTrrR)r4rjrrj) rrrrrJrLrQrVr`rcrhr3rrrrrjs      )rrrr)rr$)% __future__rr7r?typingr wandb.protorpbrrWr wandb.sdkrwandb.sdk.interface.interfacer"wandb.sdk.interface.interface_sockr wandb.sdk.libr wandb.sdk.lib.exit_hooksr wandb.sdk.lib.mailboxr wandb.sdk.lib.sock_clientr rwandb.sdk.servicerr,rrrr#r r!rrrrrs,              )