o -wi@szdZddlZddlmZddlmZmZddlmZddl m Z er.ddl m Z dd l mZed ZGd d d e ZdS) zInterfaceQueue - Derived from InterfaceShared using queues to send to internal thread. See interface.py for how interface classes relate to each other. N) BaseProcess) TYPE_CHECKINGOptional)Mailbox)InterfaceShared)Queue)wandb_internal_pb2wandbc sheZdZ    ddeddeddeedeeddf fd d Zdd d d eeddfddZZ S)InterfaceQueueNrecord_qzQueue[pb.Record]result_qzQueue[pb.Result]processmailboxreturncs$||_||_||_tj|ddS)N)r)r r _processsuper__init__)selfr r rr __class__`/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/wandb/sdk/interface/interface_queue.pyrszInterfaceQueue.__init__recordz pb.RecordlocalcCs>|jr |js td|r||j_|jr|j|dSdS)Nz&The wandb backend process has shutdown)ris_alive Exceptioncontrolrr put)rrrrrr_publish%szInterfaceQueue._publish)NNNN)N) __name__ __module__ __qualname__rrrrboolr __classcell__rrrrr s"$ r )__doc__loggingmultiprocessing.processrtypingrrwandb.sdk.mailboxrinterface_sharedrqueuer wandb.protor pb getLoggerloggerr rrrrs