h (SSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r J r J r J r SSKJr SSKJr SSKJrJrJrJr SSKJrJrJr \ (aSS KJr "S S 5rS \S \4SjrS\S\S\ \S\ \S \4 SjrSr S\ \\4S \4Sjr!g)N)Path) TYPE_CHECKINGDictListOptional)msg)Errors)check_spacy_env_vars download_file ensure_pathy get_checksum)get_hash make_tempdir upload_file) CloudPathc \rSrSrSrSS.S\S\4SjjrS\S \S \S S 4S jrSSS.S\S \ \S \ \S \ S 4Sjjr SSS.S\S \ \S \ \S \ S 4Sjjr S\S \S \S S 4Sjr S\S \4Sjr Srg) RemoteStoragezPush and pull outputs to and from a remote file storage. Remotes can be anything that `smart_open` can support: AWS, GCS, file system, ssh, etc. gz) compression project_rooturlc<Xl[U5UlX0lgN)rootr rr)selfrrrs S/home/james-whalen/.local/lib/python3.13/site-packages/weasel/cli/remote_storage.py__init__RemoteStorage.__init__s $&path command_hash content_hashreturnrc:URU- nUR5(d[SUS35eURXU5nUR5(aU$[ 5nX`R [ U55- nUR(aSUR3OSn[R"XxS9n U R[ U5[ U5S9 SSS5 [Xu5 SSS5 U$!,(df  N#=f!,(df  U$=f)aCompress a file or directory within a project and upload it to a remote storage. If an object exists at the full URL, nothing is done. Within the remote storage, files are addressed by their project path (url encoded) and two user-supplied hashes, representing their creation context and their file contents. If the URL already exists, the data is not uploaded. Paths are archived and compressed prior to upload. z Cannot push z: does not exist.zw:wmode)arcnameN) rexistsIOErrormake_urlr encode_namestrrtarfileopenaddr) rr"r#r$locrtmptar_loc mode_stringtar_files rpushRemoteStorage.push sii$zz||L->?@ @mmD = ::<<J ^s,,SY77G595E5EBt//013Kg8H SXs4y 99  %   98^  s%'AD :#C:D : D D  DNr#r$cD^ URU- nUR5(agURXUS9nUcU$URR5(dURR SS9 [ 5nXeR S- n[XW5 UR(aSUR3OSn[R"XxS9n S m U 4S jn U "XR5 SSS5 SSS5 U$!,(df  N=f!,(df  U$=f) zRetrieve a file from the remote cache. If the file already exists, nothing is done. If the command_hash and/or content_hash are specified, only matching results are returned. If no results are available, an error is raised. Nr:T)parentszr:rr(c[RRU5n[RRU5n[RRX#/5nXB:H$r)osr"abspath commonprefix) directorytarget abs_directory abs_targetprefixs ris_within_directory/RemoteStorage.pull..is_within_directoryZsF(* (B %'WW__V%< !#!5!5}6Q!R%66r!c>>UR5HRn[RRXR5nT"X5(aM;[ [ R5e [RS:aURUSS9 gURU5 g)N) data)filter) getmembersr@r"joinname ValueErrorr E201sys version_info extractall)tarr"member member_pathrHs r safe_extract(RemoteStorage.pull..safe_extract`sp&)nn&6F*,'',,t[[*IK#6t#I#I&0&= ='7++w6NN4N?NN40r!) rr+findparentmkdirrpartsr rr0r1) rr"r#r$destrr4r5r6r7rZrHs @rpullRemoteStorage.pull8syy4 ;;==iiliS ;J;;%%'' !!$!/3 " -c+9=9I9I4#3#3"45s \\'< 7 1!995-=  6 /=<  6 s%>ADC?-D? D D DcUR[U55n/nUb3Ub0URU- U- U- nUR5(aU/O/nOUbOURU- U- R5(a)[ URU- U- R 55nOURU- R5(alURU- R 5H"nUR UR 55 M$ Ub&UVs/sHofRSU:XdMUPM nn[U5S:aURSS9 U(aUS$S$s snf![a [R"S5 N5f=f)zFind the best matching version of a file within the storage, or `None` if no match can be found. If both the creation and content hash are specified, only exact matches will be returned. Otherwise, the most recent matching file is preferred. Nr=r c6UR5R$r)statst_mtime)xs r$RemoteStorage.find..s(9(9r!)keyzkUnable to sort remote files by last modified. The file(s) pulled from the cache may not be the most recent.) r.r/rr+listiterdirextendr_lensort Exceptionrwarn)rr"r#r$rQurlsrsub_dirs rr\RemoteStorage.findms\D *  # (@((T/L0<?CJJLLC5bD  %4,.6688TXX_|;DDFG4'')) $488:GKK 12 ;++/Q4C99R=L3PC4DQ t9>  9 :  tBx)T)R H sE!+E!E&& F F c\URUR[U55- U- U- $)zCConstruct a URL from a subpath, a creation hash and a content hash.)rr.r/)rr"r#r$s rr-RemoteStorage.make_urls*xx$**3t955 D|SSr!rQc@[RRU5$)z&Encode a subpath into a URL-safe name.)urllibparse quote_plus)rrQs rr.RemoteStorage.encode_names||&&t,,r!)rrr)__name__ __module__ __qualname____firstlineno____doc__rr/rr8rrar\r-r.__static_attributes__r!rrrs EI'T'' S 8'+&* 33sm 3 sm 3 +  3r'+&* "*"*sm "* sm "* +  "*HTTTTCTKT---r!rr3r%c[U5$r)r)r3s rget_content_hashrs  r! site_hashenv_hashdepscmdc[5 [U5Vs/sHn[U5PM nnX/U-nURU5 SR U5R S5n[ R"U5R5$s snf)zCreate a hash representing the execution of a command. This includes the currently installed packages, whatever environment variables have been marked as relevant, and the command. utf8) r sortedrrmrPencodehashlibmd5 hexdigest)rrrrdep dep_checksumshashescreation_bytess rget_command_hashrsv28,?,3\#&,M? "] 2F MM#WWV_++F3N ;;~ & 0 0 22 @sB cH[R"5n[R(a$UR[R"55 [ 5nUHxn[ U5nUR5HVnURSRS5(dM(URURSRSS55 MX Mz SR[U55RS5n[R "U5R#5$)zHash the current Python environment's site-packages contents, including the name and version of the libraries. The list we're hashing is what `pip freeze` would output. r=z dist-infoz .dist-inforr)sitegetsitepackagesENABLE_USER_SITErmgetusersitepackagessetrrlr_endswithr2replacerPrrrmd5sumr) site_dirspackagessite_dirsubpath package_bytess r get_site_hashrs $$&I 1134uH>'')G}}R ))+66 W]]2.66|RHI* GGF8,-44V>- ( 2 2 44r!envc0nUR5HFup#URS5(a'[RR USSS5X'MBX1U'MH [ U5$)zConstruct a hash of the environment variables that will be passed into the commands. Values in the env dict may be references to the current os.environ, using the syntax $ENV_VAR to mean os.environ[ENV_VAR] $Nr)items startswithr@environgetr)renv_varsrjvalues r get_env_hashrs\Hiik    C JJNN59b9HM!SM " H r!)"rr@rrTr0 urllib.parserxpathlibrtypingrrrrwasabirerrorsr utilr r r rrrr cloudpathlibrrr/rrrrrr!rrs 66RR66&C-C-L$3 3 3! 3)-d 3:>s) 3 35$ d38n  r!