o xi@sddlmZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m ZddlmZdd lmZdd lmZeeZGd d d eZGd ddZdS)) annotationsN) Awaitable)Callable)wandb_internal_pb2)wandb_server_pb2)asyncio_manager) MailboxHandle)MailboxResponseHandlec@seZdZdZdS)MailboxClosedErrorz/The mailbox has been closed and cannot be used.N)__name__ __module__ __qualname____doc__rrM/home/ubuntu/.local/lib/python3.10/site-packages/wandb/sdk/mailbox/mailbox.pyr sr c@sBeZdZdZddd Zdd dZdddZdddZdddZdS)Mailboxa9Matches service responses to requests. The mailbox can set an address on a server request and create a handle for waiting for a response to that record. Responses are delivered by calling `deliver()`. The `close()` method abandons all handles in case the service process becomes unreachable. asyncerasyncio_manager.AsyncioManagercancel Callable[[str], Awaitable[None]]returnNonecCs&||_||_i|_t|_d|_dS)zCreate a mailbox. Args: asyncer: Asyncio runner for scheduling async operations. cancel: A callback that can be used to cancel a request by ID. FN)_asyncer_cancel_handles threadingLock _handles_lock_closed)selfrrrrr__init__!s    zMailbox.__init__requestspb.ServerRequest | pb.Record!MailboxHandle[spb.ServerResponse]cCst|tjr6|j}s|jjj}rtd|d|}||_| dr+||jj_| dr5||j j_n|jj}rDtd|d|}||j_|j |j rVt t||j|jd}||j|<Wd|S1sowY|S)aSet a response address on a request. Args: request: The request on which to set a request ID or mailbox slot. This is mutated. An address must not already be set. Returns: A handle for waiting for the response to the request. Raises: MailboxClosedError: If the mailbox has been closed, in which case no new responses are expected to be delivered and new handles cannot be created. z Request already has an address ()record_publishrecord_communicate)rrN) isinstancespb ServerRequest request_idr&control mailbox_slot ValueError _new_addressHasFieldr'rrr r rrr)r r"addresshandlerrrrequire_response3s:            zMailbox.require_responsestrcCs,dd}|}||jvr|}||jvs |S)z[Returns an unused address for a request. Assumes `_handles_lock` is held. cSsdddtdDS)Ncss"|] }ttjtjVqdS)N)secretschoicestringascii_lowercasedigits).0_rrr ls  z9Mailbox._new_address..generate.. )joinrangerrrrgenerateks z&Mailbox._new_address..generate)r)r rAr1rrrr/es   zMailbox._new_addressresponsespb.ServerResponsecs|j}|s$|d}|dkr|jd}d|}td|dS|j|j|d}Wdn1s9wY|rJ||IdHdSdS)zDeliver a response from the service. If the response address is invalid, this does nothing. It is a no-op if the mailbox has been closed. server_response_typeresult_communicate result_typezresult_communicate.z(Received response with no mailbox slot: N) r+ WhichOneofrE_loggererrorrrpopdeliver)r rBr1kindrFr2rrrrKys   zMailbox.delivercCsl|j)d|_tdt|jd|jD]}|q|jWddS1s/wYdS)zXIndicate no further responses will be delivered. Abandons all handles. TzClosing mailbox, abandoning z handles.N) rrrHinfolenrvaluesabandonclear)r r2rrrcloses  "z Mailbox.closeN)rrrrrr)r"r#rr$)rr4)rBrCrr)rr) r r rrr!r3r/rKrRrrrrrs   2 r) __future__rloggingr6r8rcollections.abcrtypingr wandb.protorpbrr) wandb.sdk.librmailbox_handler response_handler getLoggerr rH Exceptionr rrrrrs