o -wi"@sddlmZddlZddlmZddlmZddlmZ ddlm Z ddl m Z ddl mZdd lmZdd lmZdd lmZdd lmZmZdd lmZmZmZddlmZmZGdddeZ dddZ!dddZ"GdddZ#dS)) annotationsN)Callable)wandb_internal_pb2)wandb_server_pb2)wandb_settings_pb2)wandb_settings) InterfaceBase) InterfaceSock)MessageSockRouter) ExitHooks) SockClientSockClientClosedError)HandleAbandonedErrorMailboxMailboxClosedError)service_process service_tokenc@seZdZdZdS)WandbAttachFailedErrorzFailed to attach to a run.N)__name__ __module__ __qualname____doc__rre/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/wandb/sdk/lib/service/service_connection.pyrsrsettingswandb_settings.SettingsreturnServiceConnectioncCs$t}|rt|ddSt|S)z=Connect to the service process, starting one up if necessary.N)clientproc)rfrom_envrconnect_start_and_connect_service)rtokenrrrconnect_to_servicesr%cs^t|}|j}|jtfddt||fdddt S)zStart 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. csjdSN)teardown exit_coder)connhooksrrteardown_atexit5sz3_start_and_connect_service..teardown_atexitcs tSr&)atexit unregisterr)r+rr;s z,_start_and_connect_service..)rr cleanup) rstartr$r" save_to_envr hookrr,register)rr rr)r)r*r+rr#$s    r#c@sdeZdZdZ d'd(d d Zd)ddZd*ddZd+ddZd,ddZd-ddZ d+d d!Z d.d%d&Z dS)/rz1A connection to the W&B internal service process.Nrr r %service_process.ServiceProcess | Noner/Callable[[], None] | NonecCs4||_||_d|_||_t|_t|j|j|_dS)aReturns a new ServiceConnection. Args: mailbox: The mailbox to use for all communication over the socket. router: A handle to the thread that reads from the socket and updates the mailbox. 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_cleanupr_mailboxr _router)selfrr r/rrr__init__Fs zServiceConnection.__init__ stream_idstrrrcCst|j|j|dS)z8Returns an interface for communicating with the service.)r>)r r6r:)r<r>rrrmake_interface^sz ServiceConnection.make_interfacerecord pb.RecordNonecCs|j|dS)zSend data to the service.N)r6send_record_publish)r<rArrr send_recordbszServiceConnection.send_recordrwandb_settings_pb2.Settingsrun_idcC4t}|j|||j_|jtj|ddS)z$Send an init request to the service.) inform_initN) spbServerInformInitRequestrCopyFrom_infor>r6send_server_request ServerRequestr<rrGrequestrrrrIf zServiceConnection.inform_initcCs(t}||j_|jtj|ddS)z&Send an finish request to the service.) inform_finishN)rJServerInformFinishRequestrMr>r6rNrO)r<rGrQrrrrSqszServiceConnection.inform_finish attach_idc Csvt}||jj_z|j|}|j||j dd}W|jjSt t t fy/t ddty:t ddw)zvSend an attach request to the service. Raises a WandbAttachFailedError if attaching is not possible. )timeoutz5Failed to attach: the service process is not running.NzFailed to attach because the run does not belong to the current service process, or because the service process is busy (unlikely).)rJrO inform_attachrMr>r:require_responser6rNwait_orrrr r TimeoutErrorinform_attach_responser)r<rUrQhandleresponserrrrXws(    zServiceConnection.inform_attachcCrH)z$Send a start request to the service.) inform_startN) rJServerInformStartRequestrrLrMr>r6rNrOrPrrrr_rRzServiceConnection.inform_startr(int int | NonecCsd|jrtdd|_|jr||j|jsdSt|j t j t j |dd|jS)axClose the connection. Stop reading responses on the connection, and if this connection owns the service process, send a teardown message and wait for it to shut down. This may only be called once. Returns: The exit code of the service process, or None if the process was not owned by this connection. zAlready torn down.TN)r()inform_teardown) r8AssertionErrorr9r;joinr7rclear_service_in_envr6rNrJrOServerInformTeardownRequest)r<r(rrrr's"   zServiceConnection.teardownr&)rr r r4r/r5)r>r?rr)rArBrrC)rrFrGr?rrC)rGr?rrC)rUr?rrF)r(rarrb) rrrrr=r@rErIrSrXr_r'rrrrrCs      )rrrr)$ __future__rr,typingr wandb.protorpbrrJr wandb.sdkrwandb.sdk.interface.interfacer"wandb.sdk.interface.interface_sockr wandb.sdk.interface.router_sockr wandb.sdk.lib.exit_hooksr wandb.sdk.lib.sock_clientr r wandb.sdk.mailboxrrrrr Exceptionrr%r#rrrrrs$