%`iUddlZddlZddlZddlmZmZddlmZmZm Z m Z m Z ddl m Z mZdZdaeeed<daee ed<dZd aejeZd Zd ee fd Zd edeeefd efdZded efdZdS)N)DictOptional) parse_qslunquote urlencodeurlparse urlunparse)Versionparse!RAY_DISABLE_PYARROW_VERSION_CHECK_PYARROW_INSTALLED_PYARROW_VERSION9.0.0FctjdddkrdStstjtddkrdadSt }|4|t tkrtdtd|dn#t d td dadSdS) z=Checks that Pyarrow's version is within the supported bounds. RAY_DOC_BUILD01NTzDataset requires pyarrow >= z, but z: is installed. Reinstall with `pip install -U "pyarrow"`. zYou are using the 'pyarrow' module, but the exact version is unknown (possibly carried as an internal component by another module). Please make sure you are using pyarrow >= z+ to ensure compatibility with Ray Dataset. ) osenvironget_PYARROW_VERSION_VALIDATED"_RAY_DISABLE_PYARROW_VERSION_CHECKget_pyarrow_version parse_version_PYARROW_SUPPORTED_VERSION_MIN ImportErrorloggerwarning)versions l/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/_private/arrow_utils.py_check_pyarrow_versionr!s z~~os++s22 %* :>> ddl}dat|drt|jan#t $rdaYnwxYwt S)z@Get the version of the pyarrow package or None if not installed.FNrT __version__)r pyarrowhasattrrr%rModuleNotFoundError)r&s r rr9sU""t! ' NNN!% w .. F#01D#E#E " ' ' '!&    ' s*? A Aurlparamsc|t|}t|}|}tt|j}|||d|Dt|d}||}t|S)aAdd params to the provided url as query parameters. If url already contains query parameters, they will be merged with params, with the existing query parameters overriding any in params with the same parameter name. Args: url: The URL to add query parameters to. params: The query parameters to add. Returns: URL with params added as query parameters. cvi|]6\}}t|ttf!|tj|7S) isinstancebooldictjsondumps).0kvs r z)_add_url_query_params..csJ   1!dD\** tz!}}   r"T)doseq)query) rrr0rr8updateitemsr_replacer )r)r* parsed_url base_paramsencoded_paramss r _add_url_query_paramsr?Ls #,,C#JK )J,-- . .Fv  #))++   {$777N$$>$::J j ! !!r"urict}||tdkr|St|}|jdkrt |ddi}|S)aDIf the provided URI is an S3 URL, add allow_bucket_creation=true as a query parameter. For pyarrow >= 9.0.0, this is required in order to allow ``S3FileSystem.create_dir()`` to create S3 buckets. If the provided URI is not an S3 URL or if pyarrow < 9.0.0 is installed, we return the URI unchanged. Args: uri: The URI that we'll add the query parameter to, if it's an S3 URL. Returns: A URI with the added allow_bucket_creation=true query parameter, if the provided URI is an S3 URL; uri will be returned unchanged otherwise. Nrs3allow_bucket_creationT)rrrschemer?)r@pyarrow_version parsed_uris r %add_creatable_buckets_param_if_s3_urirGrs_ *++O"w9O9O'O'O #JD  #C*A4)HII Jr")r1loggingrtypingrr urllib.parserrrrr packaging.versionr r rrr r/__annotations__rrr getLogger__name__rr!rstrr?rGr-r"r rPs^  !!!!!!!!LLLLLLLLLLLLLL========%H"&*HTN)))&*(7#*** ")"  8 $ $***>Xg.&#"s#"DcN#"s#"#"#"#"Lssr"