o V h%@sddlZddlZddlZddlZddlZddlmZddlZddlm Z ddl m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZejddZejdd Zed Zd Z d e!d e"fddZ#ddZ$dddZ%GdddZ&e&Z'dS)N)Path) __version__)ARGV ENVIRONMENTIS_COLAB IS_GIT_DIRIS_PIP_PACKAGELOGGERONLINERANKSETTINGS TESTS_RUNNINGTQDM TryExceptcolorstrget_git_origin_url)GITHUB_ASSETS_NAMESULTRALYTICS_HUB_APIzhttps://api.ultralytics.comULTRALYTICS_HUB_WEBzhttps://hub.ultralytics.comzUltralytics HUB: z]If this issue persists please visit https://github.com/ultralytics/hub/issues for assistance.urlreturncCsFtstdddlm}ddlm}||d|d|dS)a/ Make an AJAX request with cookies attached in a Google Colab environment. Args: url (str): The URL to make the request to. Returns: (Any): The response data from the AJAX request. Raises: OSError: If the function is not run in a Google Colab environment. z:request_with_credentials() must run in a Colab environmentr)output)displayz window._hub_tmp = new Promise((resolve, reject) => { const timeout = setTimeout(() => reject("Failed authenticating existing browser session"), 5000) fetch("a", { method: 'POST', credentials: 'include' }) .then((response) => resolve(response.json())) .then((json) => { clearTimeout(timeout); }).catch((err) => { clearTimeout(timeout); reject(err); }); }); _hub_tmp)rOSError google.colabrIPythonr Javascripteval_js)rrrrI/var/www/vscode/kcb/lib/python3.10/site-packages/ultralytics/hub/utils.pyrequest_with_credentials&s    r!cKs|dd}|stj||fi|Stj||fddi|}tt|tr+|jddn|}zt|dddd }|j dd D] }| t |q=| W|Stj jy]| Y|Sw) a Make an HTTP request using the specified method and URL, with an optional progress bar. Args: method (str): The HTTP method to use (e.g. 'GET', 'POST'). url (str): The URL to send the request to. **kwargs (Any): Additional keyword arguments to pass to the underlying `requests.request` function. Returns: (requests.Response): The response object from the HTTP request. Notes: - If 'progress' is set to True, the progress bar will display the download progress for responses with a known content length. - If 'progress' is a number then progress bar will display assuming content length = progress. progressFstreamTzcontent-lengthrBi)totalunit unit_scale unit_divisor) chunk_size)poprequestsrequestint isinstanceboolheadersgetr iter_contentupdatelenclose exceptionsChunkedEncodingError)methodrkwargsr"responser%pbardatarrr requests_with_progressOs    r=TFc  s^dtdfdd} ||f} ||d<|r(tj| | |dddS| | i|S) a Make an HTTP request using the 'requests' library, with exponential backoff retries up to a specified timeout. Args: method (str): The HTTP method to use for the request. Choices are 'post' and 'get'. url (str): The URL to make the request to. retry (int, optional): Number of retries to attempt before giving up. timeout (int, optional): Timeout in seconds after which the function will give up retrying. thread (bool, optional): Whether to execute the request in a separate daemon thread. code (int, optional): An identifier for the request, used for logging purposes. verbose (bool, optional): A flag to determine whether to print out to console or not. progress (bool, optional): Whether to show a progress bar during the request. **kwargs (Any): Keyword arguments to be passed to the requests function specified in method. Returns: (requests.Response): The HTTP response object. If the request is executed in a separate thread, returns None. )ii)verbosec s8d}t}tdD]}t|kr|St||fi|}|jdkr*|Sz |dd}Wn ty?d}Ynw|dkr|jvrY|rUdd d nd 7}n|jd krs|j}d |dd|dd|dd }rt t |dt d|jdd |jvr|St d|q |S)zNMake HTTP requests with retries and timeouts, with optional progress tracking.Ni,messagezNo JSON message.zUnable to read JSON.rz Retrying zx for zs.izRate limit reached (zX-RateLimit-Remaining/zX-RateLimit-Limitz). Please retry after z Retry-After z (z #)) timeranger= status_codejsonr1AttributeErrorr0r warningPREFIXHELP_MSGsleep) func_methodfunc_url func_kwargsrt0imhcoderetry retry_codestimeoutrArr funcs<     ( zsmart_request..funcr"T)targetargsr9daemonN)r threadingThreadstart) r8rr\r^threadr[rAr"r9r_rarrZr smart_requestosrgc@s$eZdZdZdZddZddZdS)Eventsa A class for collecting anonymous event analytics. Event analytics are enabled when sync=True in settings and disabled when sync=False. Run 'yolo settings' to see and update settings. Attributes: url (str): The URL to send anonymous events. rate_limit (float): The rate limit in seconds for sending events. metadata (dict): A dictionary containing metadata about the environment. enabled (bool): A flag to enable or disable Events based on certain conditions. zihttps://www.google-analytics.com/mp/collect?measurement_id=G-X8NCJYTQXM&api_secret=QLQrATrNSwGRFRLE-cbHJwcCsg|_d|_d|_ttdjdktrdntrdnddt d d t t t td d d |_tdoEtdvoEt oEtoEtpEtdk|_d S)zVInitialize the Events object with default values for events, rate_limit, and metadata.g>@gryologitpipother.NrHg4&k Ci)cliinstallpythonversionenv session_idengagement_time_msecsync>rr@z.https://github.com/ultralytics/ultralytics.git)events rate_limittrrnamerrjoinplatformpython_version_tuplerrroundrandommetadatar r r r renabled)selfrrr __init__s(  zEvents.__init__cCs|jsdSt|jdkr3i|j|j|jtvr|jndd}|jdkr)|j|d<|j |j|dt }||j |j krAdSt d|jd }td |j|d d d g|_||_ dS)z Attempt to add a new event to the events list and send events if the rate limit is reached. Args: cfg (IterableSimpleNamespace): The configuration object containing mode and task information. Ncustom)taskmodelexportformat)ryparamsuuid) client_idrvpostrF)rLr\rA)rr4rvrrrrmoderappendrIrxrwr rgr)rcfgrrxr<rrr __call__s&   zEvents.__call__N)__name__ __module__ __qualname____doc__rrrrrrr rhs   rh)r>r?Tr@TF)(osr{r~rcrIpathlibrr+ ultralyticsrultralytics.utilsrrrrrr r r r r rrrrultralytics.utils.downloadsrenvironr1 HUB_API_ROOT HUB_WEB_ROOTrOrPstranyr!r=rgrhrvrrrr s&  @ ) ; N