wi{ddlmZddlmZddlmZddlmZmZm Z ddl m Z m Z ddl mZdadadae ZdefdZdefd Zdefd Zd ede fd Zd ee ddfdZde eeeffdZdS))Lock) BaseProxy)DictOptionalTuple)DashboardManager!DashboardManagerConnectionDetails)ignore_keyboard_interruptNreturnc"tiatS)zY :return: Dashboard tqdm dict which should be used in a DashboardManager context )DASHBOARD_TQDM_DICTo/var/www/development/aibuddy-work/election-extract/venv/lib/python3.11/site-packages/mpire/dashboard/manager.pyget_dashboard_tqdm_dictrs "  rc"tiatS)za :return: Dashboard tqdm details dict which should be used in a DashboardManager context )DASHBOARD_TQDM_DETAILS_DICTrrrget_dashboard_tqdm_details_dictr!s #*&(# &&rc:ttatS)zY :return: Dashboard tqdm lock which should be used in a DashboardManager context )DASHBOARD_TQDM_LOCKrrrrget_dashboard_tqdm_lockr+s ""ff rmanager_port_nrctjdttjdttjdttd|fd}|t |a|a|a dt_ |t_ |S)z Start a SyncManager :param manager_port_nr: Port number to use for the manager :return: SyncManager and hostname rrrz 127.0.0.1mpire_dashboardaddressauthkey) rregisterrrrstartr r rr$DASHBOARD_MANAGER_CONNECTION_DETAILShostport)rdms rstart_manager_serverr$5s79PQQQ?A`aaa79PQQQ ;"@J\ ] ] ]BHH &'''4466"$"D"D"F"F44661<(-0?(- Irmanagercp||dadadatdS)z[ Shutdown a DashboardManager :param manager: DashboardManager to shutdown N)shutdownr rrr clear)r%s rshutdown_manager_serverr)QsF"&(..00000rcttttfStjdt tjdt tjdtttj tj fd}| |a|a|atttfS)z Connect to a DashboardManager and obtain the synchronized tqdm dashboard dicts :return: DashboardManager tqdm dict, tqdm details dict, tqdm lock Nrrrrr) r rrrrrrrr r!r"connect)r#s rget_manager_client_dictsr,`s&"$?ATTT79PQQQ?A`aaa79PQQQ 5:<`r5s 888888......((((((((((bbbbbbbb222222#(I'H'J'J$'''''#2B8 1X.>%? 1D 1 1 1 1Q% 9i(G"HQQQQQQr