o vi!@stddlmZmZddlmZddlmZededfddZedd ededfd d Z ededfd d Z dS)) ExitStackcontextmanager) Generator)timerreturn)NNNc#Ltdg}tfdd|DVWddS1swYdS)zo Wrap the data loader initialization with multiple context managers used for telemetry and one logger. Zinit_data_loadercg|]}|qS enter_context.0cmstackr Z/data/cameron/vidgen/cosmos-policy/cosmos_policy/_src/imaginaire/utils/context_managers.py z$data_loader_init..Nrrcontextsr rrdata_loader_init "rF set_barrierc#sLtdg}tfdd|DVWddS1swYdS)zo Wrap the instantiation of the model with multiple context managers used for telemetry and one logger. Z init_modelcrr r r rr rr+rzmodel_init..Nr)rrr rr model_init"rrc#r)zL Wrap the distributed initialization, used for telemetry and timers init_distributedcrr r r rr rr7rz$distributed_init..Nrrr rrdistributed_init.rrN)F) contextlibrrtypingr(cosmos_policy._src.imaginaire.utils.miscrrboolrrr r r rs