5inhdZddlmZmZmZmZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddlmZmZdd lmZmZd>d Zedd fd ZiZGd deZe j4dZe j4dZe j4dZe j4dZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+d Z,d!Z-d"Z.d#Z/d$Z0d%Z1d&Z2d?d'Z3d@d(Z4dAd)Z5d*Z6dBd+Z7ifd,Z8 dCd-Z9d.Z: dDd/Z;dEd0Z dFd3Z?d4Z@d5ZAd6ZBd7ZCd8ZDd9ZEd?d:ZFd@d;ZGd?d<ZHd=ZIy)Gz This file contains all the utilities needed for escaping and parsing names in the syntax of project-ID-or-name:folder/path/to/filename For more details, see external documentation [TODO: Put link here]. )print_functionunicode_literalsdivisionabsolute_importN) get_ls_l_desc) basestring)try_callINTERACTIVE_CLI) DXCLIErrorDXErrorct|dk(rd}|Stt|D]R}t|dz}||jd} ddt|zz} t || j | zT|r t dt d|,d}|r|d z }n|r|d z }||d t|zd zz }|d z } t |} || dk(r|S|r| dk(r| S|r| dk(r| S |j| }|S#t$r t dt$r t dwxYw#YnxYw t| }|tt|vr t|S#t$rt dYnwxYw)a :param choices: Strings between which the user will make a choice :type choices: list of strings :param default: Number the index to be used as the default :type default: int or None :param str_choices: Strings to be used as aliases for the choices; must be of the same length as choices and each string must be unique :type str_choices: list of strings :param prompt: A custom prompt to be used :type prompt: string :param allow_mult: Whether "*" is a valid option to select all choices :type allow_mult: boolean :param more_choices: Whether "m" is a valid option to ask for more options :type more_choices: boolean :returns: The user's choice, i.e. one of a numbered index of choices (e.g. 0 for the first item), "*" (only if allow_mult is True), or "m" (only if more_results is True) :rtype: int or string :raises: :exc:`EOFError` to signify quitting the process At most one of allow_mult and more_choices should be set to True. rrz)   zm) More options not shown...zPick a numbered choicez or "*" for allz or "m" for more optionsz []z: *mzNot a valid selection) lenrangestrsplitprintjoininputKeyboardInterruptEOFErrorindexint IndexError Exception) choicesdefault str_choicesprompt allow_mult more_choiceschoiceiprefixlinesjoinervalues u/home/marpiech/ifpan-abm-pgxpred/analysis/marpiech-gwas-test/venv/lib/python3.12/site-packages/dxpy/utils/resolver.pypickr0$s( 7|q 3w< +Q$   &c&k)) fv{{5))* +  ,- "I ~)  ' 'F  0 0F   dS\)C/ /F$  &ME  5B;N %3,L ESLL  &&u-FM!  "I   "I     +ZFU3w<00 l"M + ) * +3 s* C>+D+>*D(+D/3,E E76E7 c d} g}t||krMt|d}|n>||j|n||r|j|d}t||krM|syt|dk(ry t|Dcgc] }|| c}fdt||k(i|} | dk(r|| Scc}w#t$rYywxYw)NFTz none foundrz none pickedr(r)rnextappendr0r) generator render_fn filter_fnpage_len pick_opts any_resultsresults possible_nextresultr)s r/paginate_and_pickr>isK 'lX% D1M$ }-]+NN=1K'lX% \Q   !7C9V,C'(+G (@'%'F S= 6? "D! !  !s$4 B2=B- B2-B22 B>=B>ceZdZdZdZy)ResolutionErrorc||_yNmsg)selfrDs r/__init__zResolutionError.__init__s c|jSrBrC)rEs r/__str__zResolutionError.__str__s xxrGN)__name__ __module__ __qualname__rFrIrGr/r@r@s rGr@z8^(record|applet|file|workflow|database)-[0-9A-Za-z]{24}$zj^(record|app|applet|workflow|globalworkflow|job|analysis|project|container|file|database)-[0-9A-Za-z]{24}$z$^(user|org|app|globalworkflow|team)-z7^(job|analysis)-[0-9A-Za-z]{24}:[a-zA-Z_][0-9a-zA-Z_]*$c0tj|duSrB) hash_patternmatchstrings r/ is_hashidrS   f %T 11rGc0tj|duSrB)data_obj_patternrPrQs r/is_data_obj_idrWs  ! !& ) 55rGcdt|xr$|jdxs|jdS)Nproject-z container-rS startswithrQs r/is_container_idr\s. V  c&"3"3J"?"b6CTCTUaCbcrGc>t|xr|jdS)NrYrZrQs r/ is_project_idr^s V  >!2!2:!>>rGc>t|xr|jdS)Nz analysis-rZrQs r/is_analysis_idr`s V  ?!2!2;!??rGc>t|xr|jdS)Nzjob-rZrQs r/ is_job_idrbs V  :!2!26!::rGcjtjjdduxr|jdS)N DX_JOB_IDz localjob-)osenvirongetr[)things r/is_localjob_idris* JJNN; '4 / QE4D4D[4QRrGc0tj|duSrB)nohash_patternrPrQs r/ is_nohash_idrls    't 33rGcBtd|dk\xstd|dk\S)Nrr?)get_last_pos_of_charrQs r/is_glob_patternrps( f - 2 _8LSRX8Y]^8^_rGc0tj|duSrB) jbor_patternrPrQs r/ is_jbor_strrsrTrGc0t|}t| S)zL Returns True if the specified path explicitly specifies a project. )!_maybe_convert_stringified_dxlinkrSpaths r/is_project_explicitrxs -T 2D rGc| td| tdt|std|dttjd|zdzd|id d|k(S) z :param obj_id: object ID :type obj_id: str :param proj_id: project ID :type proj_id: str Returns True if the specified data object can be found in the specified project. zExpected obj_id to be a stringzExpected proj_id to be a stringz Expected z to be a container ID/ /describeprojectT) always_retry) ValueErrorr\r dxpy DXHTTPRequest)obj_idproj_ids r/object_exists_in_projectrsy~9:::;; 7 #wHII D&&f {(BYPWDXgk lmv w|C CCrGc*d|jdzS)N\rgrouprPs r/escaperrs %++a.  rGcXtjdt|jddS)Nz([#\?\*: ;&`"'!$\(\)\{\[<>|~])r\\resubrreplacerQs r/escape_folder_strrs" 663WfnnTSY>Z [[rGcXtjdt|jddS)Nz([#\?\*: ;&`"'/!$\(\)\{\[<>|~])rrrrQs r/escape_name_strrs" 664gv~~dTZ?[ \\rGc*|jddS)Nrrrrs r/ unescaperrs ;;q>! rGcXtjdt|jddS)Nz(\\[#\?*: ;&`"'!$\(\){[<>|~])rrrrrrrQs r/unescape_folder_strrs% 663Y G O OPVX\ ]]rGcXtjdt|jddS)Nz(\\[#\?*: ;&`"'/!$\(\){[<>|~])rrrrQs r/unescape_name_strrs% 664i H P PQWY] ^^rGct|}|dkDrV|d|j|}|dk(ryd}|dz }|dk\r ||dk(r|dz }|dz}|dk\r ||dk(r|dzdk(r|S|dkDrVy)a :param char: The character to find :type char: string :param string: The string in which to search for *char* :type string: string :returns: Index in *string* where *char* last appears (unescaped by a preceding "\"), -1 if not found :rtype: int Finds the last occurrence of *char* in *string* in which *char* is not present as an escaped character. rNrrr rrfind)charrRposnum_backslashes test_indexs r/roros f+C 'Tcl  & "91W Ao&"4"< q O !OJAo&"4"< Q ! #J ' rGcd}t|}|dkDrW|d|j|}|dk(r|Sd}|dz }|dk\r ||dk(r|dz }|dz}|dk\r ||dk(r|dzdk(r|}|dkDrW|S)a :param char: The character to find :type char: string :param string: The string in which to search for *char* :type string: string :returns: Index in *string* where *char* last appears (unescaped by a preceding "\"), -1 if not found :rtype: int Finds the first occurrence of *char* in *string* in which *char* is not present as an escaped character. rrNrrr r)rrR first_posrrrs r/get_first_pos_of_charr sI f+C 'Tcl  & "9 1W Ao&"4"< q O !OJAo&"4"< Q ! #I ' rGcg}t|}|}|dk\r=t||d|}|dk\r#|dz|k7s|r|j||dz||}|dk\r=|dk7s|r|j|d||j|S)av :param char: The character on which to split the string :type char: string :param string: The string to split :type string: string :returns: List of substrings of *string* :rtype: list of strings Splits *string* whenever *char* appears without an odd number of backslashes ('\') preceding it, discarding any empty string elements. rNr)rror4reverse)rrRinclude_empty_stringswordsrlastposs r/split_unescapedr's E f+CG ("4)9: !8Qw'!%: VC!GW56G ( !|, VHW%& MMO LrGctd|}t|dk(ry|dk(s+|ddk(s#|ddk(std|t|dz k(rd }nt|j }g}|D]G}|dk(r |dk(r t|dkDs|j .|j t |Iddj|z|fS) ar :param path: A folder path to sanitize and parse :type path: string :param expected: Whether a folder ("folder"), a data object ("entity"), or either (None) is expected :type expected: string or None :returns: *folderpath*, *name* Unescape and parse *path* as a folder path to possibly an entity name. Consecutive unescaped forward slashes "/" are collapsed to a single forward slash. If *expected* is "folder", *name* is always returned as None. Otherwise, the string to the right of the last unescaped "/" is considered a possible data object name and returned as such. rzr)rzNfolderr.z..rN)rrrorpopr4rr)rwexpectedfolders entity_namesanitized_foldersrs r/clean_folder_pathrDs c4(G 7|q8wr{c1WR[D5HL`adfjLkorswox{|o|L| ' 6 B S=  t^$%)!%%'  $ $%8%@ AB #((,- - ;;rGc t|}t|r|r|gS|S|tvr|r t|gSt|S tt j |dd}t|dk(r"|ddt|<|r |ddgS|ddSt|dk(r|rtd|zd z|rgSdS|s`trItd |zd zt|Dcgc]}d j|d|d  c}}||dStd |zdz|Dcgc]}|d c}S#t $r}tt|d}~wwxYwcc}wcc}w)a :param raw_string: A potential project or container ID or name :type raw_string: string :param is_error: Whether to raise an exception if the project or container ID cannot be resolved :type is_error: boolean :returns: Project or container ID if found or else None :rtype: string or None :raises: :exc:`ResolutionError` if *is_error* is True and the project or container could not be resolved Unescapes and attempts to resolve *raw_string* to a project or container ID. TVIEW)namedescribelevelNrridz Could not find a project named ""z#Found multiple projects with name "z{id} ({level})r)rrz9"; please use a project ID to specify the desired project)rr\cached_project_nameslistr find_projectsr"r@rrr rr0format) raw_stringis_errormultirRr;detailsr=r)s r/resolve_container_id_or_namerls z *Fv!.v. %%27%f-.Z=QRX=YZ,t))vFST 7|q'.qz$'7V$&+D!"BD1AB W  !"Dv"MPS"ST T&&   7&@3F G)02%,22fTl&QX/2Z23F6?4( (!"G&"PTO#OP P,33t 33) ,c'l++,24s#!D) E E) E 2EE ct tj|}t|trd|vrt|dtr|dSt|dtrZt|dj ddtr7t|dj ddtr|dddz|ddzS|S#Y|SxYw)N$dnanexus_linkr|r:)jsonloads isinstancedictr rg)rw possible_hashs r/rurus   4( mT */?=/P-(89:F$%566]+;>dS$>> 4'5""#tUYYY4;L;LtUYYYGJK d +B&c40JQ.sD*4EF a !"2T"9#?AJ#KM_#`a a#E* G lD )< 1$!,q/48,>sV|k?Y[c,d fyGy" N&i$&69X&X[a&aeA'ABB  d +0@L0P!"23F 4"(d6H6HvXcIcem6nop N ")d"25T"TW]"]aI#IJ J047:YY\bbeCGCLCLMUV^M_MdMdMfCggh ha ,c'l++,   $Hy 8)#g,778 4%c'l33 4sqH!"I II &I9I . J! I*H>>I III J)I==J J'J""J'cv|d||dfSt|r|jdd}d}|||vrd}|sy|duri}d|vr<|tjk7r||d<n#tjtj|d< tjd|zd z|} tj | } || d } |rd||| gfSd||| fSd|||fS#t $rh} d|vrF|d= tjd|zd z|} n9#t $r} tt| d} ~ wwxYwtt| Yd} ~ d} ~ wwxYw) ac :param path: Path to the object that required resolution; propagated from command-line :type path: string :param project: The potential project the entity belongs to :type project: string :param folderpath: Path to the entity :type folderpath: string :param entity_name: The name of the entity :type entity_name: string :param expected_classes: A list of expected classes the entity is allowed to belong to if it is an ID (e.g. "record", "file", "job"); if None, then entity_name may be any data object class :type expected_classes: list or None :param describe: Dictionary of inputs to the describe API call; if no describe input is provided (default value True), then an empty mapping is passed to the describe API method :type describe: dict or True :param enclose_in_list: Whether the describe output is to be in the form of a list (if False, the last return value is a dictionary; if True, the last return value is a list of one dictionary); it will only have an effect if entity_name is a DX ID and is described :type enclose_in_list: boolean :returns: Whether or not the entity needs to be resolved with a more general resolution method, the project, the folderpath, and the entity name :rtype: tuple of 4 elements :raises: ResolutionError if the entity fails to be described Attempts to resolve the entity to a folder or an object, and describes the entity iff it is a DX ID of an expected class in the list expected_classes. Otherwise, determines whether or not more general resolution may be able to resolve the entity. If a more general resolution method is needed, then the return values will look like: (True, , , ) If the entity is a DX ID, but is not one of the supplied expected classes, then the return values will look like: (False, None, None, None) If the entity can be successfully described, then the return values will look like: ::= {"id": entity_name, "describe": {...}} ::= || [] (False, , , ) If the entity may be a folder, then the return values will look like: (False, , , None) TODO: Allow arbitrary flags for the describe mapping. NF-rT)FNNNr|rzr{r) rSrrrr#append_underlying_workflow_describer"r@r) rwr|rrexpected_classesrenclose_in_list entity_classfound_valid_classdescrdetails2r=s r/_check_resolution_neededrnstgz4// ; "((-a0    'L@P,P %  * t H H $$+++&-#"".&*&7&7# 4%%cK&7+&ExPD;;DAD$6 ':x7 7':v5 5Wj+55% 4H$Y'9--cK.?+.MxXD 9)#h-889&c'l33  4s<<1C D8D3C54D35 D>DDD33D8cd|vr5tdt|zdzt|zdzt|zt|dz|zd\}}t|||std|zdz|zdz|S) a :param project: The project that the folder belongs to :type project: string :param parent_folder: Full path to the parent folder that contains folder_name :type parent_folder: string :param folder_name: Name of the folder :type folder_name: string :returns: The path to folder_name, if it exists, in the form of "/" :rtype: string :raises: ResolutionError if folder_name is not a folder, or if folder_name points to a folder that does not exist Attempts to resolve folder_name at location parent_folder in project. rzzObject of name z! could not be resolved in folder z of project ID rzUnable to resolve "z&" to a data object or folder name in '')r@rrcheck_folder_exists)r| parent_folder folder_namepossible_folder_skips r/_resolve_folderrs" k/#k2BBEhh!-013DEGJ7|TU U.}s/B[/PRZ[OU w { C3kAGHJWXZ]^_ _ rGc t|dk(r td|s|St|dkDr|r|s t|r|Strt d|zdzt |Dcgc]}d|vc}rt |d\}}}t|||}t|Dcgc]}t|dc}| } |r| d k(r|S|r|| gS|| Std|zd ztt|zd z|r|dgS|dScc}wcc}w) am :param path: Path to the object that required resolution; propagated from command-line :type path: string :param entity_name: Name of the object :type entity_name: string :param results: Result of resolution; non-empty list of object specifications (each specification is a dictionary with keys "project" and "id") :type results: list of dictionaries :param allow_mult: If True, it is okay to choose from multiple results of a single resolved object, or return all results found; if False, raise an error if multiple results are found :type allow_mult: boolean :param all_mult: If True, return all results if multiple results are found for a single resolved object; if False, user needs to choose a single result if multiple are found; the value of all_mult only has an effect if allow_mult is True) :type all_mult: boolean :param ask_to_resolve: Whether picking may be necessary (if True, a list is returned; if False, only one result is returned); if specified as True, then all results will be returned, regardless of the values of allow_mult and all_mult :type ask_to_resolve: boolean :returns: The results of resolving entity_name, expected to be of the following form: # If only one result is present or the user # is able to select from multiple OR [, ...] # If multiple results are present and # it is allowed where is of the following form: {"project": , "id": } :rtype: dict or list of dicts :raises: ValueError if results is empty :raises: ResolutionError if too many results are found and the user is not in interactive mode and cannot select one Precondition: results must be a nonempty list Validates length of results. If there are multiple results found and the user is in interactive mode, then the user will be prompted to select a single result to be returned. rz'results' must be nonempty.rThe given path "z)" resolves to the following data objects:rentityr)r'rz" resolves to z data objects) rr~rpr ranyr_resolve_global_entityr0rr@r) rwrr;r'all_multask_to_resolver=r|rr)s r/"_validate_resolution_output_lengthrs<b 7|q677  7|a 8{'CN  $t+.YY Z7CJf,CD3?x3X0[0*kR7S= );<S%/1Ffm,6(KGFOK!"4t";>N"N"%c'l"3#46E#FG G * |9wqz9DTs  DDc t|r|duri}t|||S ttj|||dd||S#t $r}t t|d}~wwxYw)a= :param project_or_job_id: The project ID to which the entity belongs (then the entity is an existing data object), or the job ID to which the entity belongs (then the entity is a job-based object reference to an object that may not exist yet) :type project_or_job_id: string :param folderpath: Full path to the object (parsed from command line) :type folderpath: string :param entity_name: Name of the object :type entity_name: string :param describe: Input mapping used to describe the job's project if project_or_job_id is a job ID, or True if the input mapping is to be empty :type describe: dict or True :param visibility: The expected visibility of the entity ("either", "hidden", or "visible"); to be used in resolution :type visibility: string :returns: The results obtained from attempting to resolve the entity; the expected format of the return value is described below :rtype: list :raises: ResolutionError if dxpy.find_data_objects throws an error If project_or_job_id is a job ID, then return value will be like: [{"id": ..., "describe": {...}}, ...] Otherwise, the return value will be like: [{"id": ..., "project": ..., "describe": {...}}, ...] Note that if the entity is successfully resolved, then the "describe" key will be in the dictionary if and only if a nonempty describe mapping was provided. TODO: Inspect entity_name and conditionally treat it as a "glob" pattern. TODO: Callers should specify exactly what fields they want, and then hopefully we can avoid having a default set of fields that may be very expensive T)rglobF)r|rr name_moderecurser visibilityN)rbrrrfind_data_objectsr"r@r)project_or_job_idrrrr rs r/rrDsN"# t H 0+QQ 0..7H6@4?9?7<8@:D FG G 0!#g,/ / 0s$A A(A##A(c t|dk(rt|||}||ddSt|||}t|rdn|d|dS#t$r ddddcYSwxYw)a :param path: Path to the object that required resolution; propagated from command-line :type path: string :param project: The potential project the entity belongs to :type project: string :param folderpath: Path to the entity :type folderpath: string :param entity_name: The name of the entity :type entity_name: string :param result: The result of resolving entity_name :type result: list of dictionaries :returns: The validated resolution output :rtype: dictionary Formats the output from the resolution of entity_name based on the number of resolved entities. If no results are found and entity_name can be resolved to a folder, then the return value will look like: {"project": , "folder": , "name": None} If exactly one result is found, then the return value will look like: {"project": , "folder": , "name": {"id": , "project": }} OR {"project": None, "folder": , "name": {"id": , "project": }} Else, the return value will look like: {"project": None, "folder": None, "name": None} rNr|rr)rrrrbr@)rwr|rrr=rvalidated_resultss r/_format_resolution_outputrswB ? v;! $Wj+FF&&$G G B4V\ ] '0'9tw",=? ? ?4>>?s AAAAci}g}g}|D]}t|d\}}} t||||\}}}}|rSt|r! t|||} t ||||| ||<V|j ||j |||d}|||d||<tj|} t||| D]!\}} } t || d| d| d| ||<#|S#d}YxYw#t $r dddd||<YwxYw) a :param paths: A list of paths to items that need to be resolved :type paths: list :returns: A dictionary mapping a specified path to either its resolved object or Nones, if the object could not be resolved :rtype: dict For each input given in paths, attempts to resolve the path, and returns the resolved object in a dictionary. The return value will look like: {: , : ,...} If entity_id is a DX ID that can be described, ::= {"project": None, "folder": None, "name": {"id": , "describe": }} Else if a general resolution (or search) method will be used to resolve the entity, ::= {"project": , "folder": None, "name": {"project": , "id": }} Else if is a job ID, ::= {"project": None, "folder": None, "name": {"project": , "id": }} Else if the path refers to a folder instead of a data object, ::= {"project": , "folder": , "name": None} Else if description or resolution fails, ::= {"project": None, "folder": None, "name": None} rrFNrr|rr) rrrprrr@r4rresolve_data_objectszip) paths done_objectsto_resolve_in_batch_pathsto_resolve_in_batch_inputsrwr|rr must_resolve find_resultsresolution_resultsinputsr=s r/resolve_multiple_existing_pathsrsqRL "!#a+7x+P([ !=Ugz;>8 :L':{ {+Y#9':{#[L)B4R\^iCO*QL&*006*11gQ[ep2qr.5 T_!`L 1a6223MN #$=?Y$6!8?ff6tVI=NPVW_P`bhiobp7=? T? 7 ! L'Y59TSW)XL&YsCC"C"C76C7c t|||\} } } t|| | | ||| xs|\} } } } | rVt| | | ||} t| dk(rt | | | }| |dfSt || | |||}t | rdd|fS| d|fS| | | fS)a :param expected: one of the following: "folder", "entity", or None to indicate whether the expected path is a folder, a data object, or either :type expected: string or None :param ask_to_resolve: Whether picking may be necessary (if true, a list is returned; if false, only one result is returned) :type ask_to_resolve: boolean :param expected_classes: A list of expected classes the entity is allowed to belong to if it is an ID (e.g. "record", "file", "job"); if None, then entity_name may be any data object class :type expected_classes: list or None :param allow_mult: Whether to allow the user to select multiple results from the same path :type allow_mult: boolean :param describe: Input hash to describe call for the results, or True if no describe input is to be provided :type describe: dict or True :param all_mult: Whether to return all matching results without prompting (only applicable if allow_mult == True) :type all_mult: boolean :returns: A LIST of results when ask_to_resolve is False or allow_mult is True :raises: :exc:`ResolutionError` if the request path was invalid, or a single result was requested and input is not a TTY :param allow_empty_string: If false, a ResolutionError will be raised if *path* is an empty string. Use this when resolving the empty string could result in unexpected behavior. :type allow_empty_string: boolean :param visibility: The visibility expected ("either", "hidden", or "visible") :type visibility: string Returns either a list of results or a single result (depending on how many is expected; if only one, then an interactive picking of a choice will be initiated if input is a tty, or else throw an error). TODO: Always treats the path as a glob pattern. Output is of the form {"id": id, "describe": describe hash} a list of those TODO: Callers should specify exactly what fields they want, and then hopefully we can avoid having a default set of fields that may be very expensive NOTE: if expected_classes is provided and conflicts with the class of the hash ID, it will return None for all fields. )rr)rrr)rr rN)r'rr)rrrrrrrb)rwrrrr'rrrr r|rrrr;rrs r/resolve_existing_pathr sV(4D8`r's$GZ5MdNUNXNY_oW_cq_q`j_i6l2L':{(*kT\ist w<1 $Wj+FFFD( ( B4CNCJNXLTR` !b  !T#444D"33 3 J ++rGc8||y tjj||dd}|dz|z}t|d\}}||dvS#tjj$r4}|j dk(rt t|j|d}~wwxYw)a :param project: project id :type project: string :param path: path to where we should look for the folder in question :type path: string :param folder_name: name of the folder in question :type folder_name: string :returns: A boolean True or False whether the folder exists at the specified path :type: boolean :raises: :exc:'ResolutionError' if dxpy.api.container_list_folder raises an exception This function returns a boolean value that indicates whether a folder of the specified name exists at the specified path Note: this function will NOT work on the root folder case, i.e. '/' NFr)ronlyResourceNotFoundrzr) rrcontainer_list_folder exceptions DXAPIErrorrr@rrDr)r|rwr folder_liste target_folderrs r/rrDs"dlhh44WW`>ab 3J,M,]HEM5 K 2 22 ?? % % 66' '!#aee*- -G s#AB%/BBcd}|jdsd|z}d|vr+||jddzd}|d|jd} tjj ||S#tj $rYywxYw)a :param path: A string to attempt to resolve to an app object :type path: string :returns: The describe hash of the app object if found, or None otherwise :rtype: dict or None This method parses a string that is expected to perhaps refer to an app object. If found, its describe hash will be returned. For more information on the contents of this hash, see the API documentation. [TODO: external link here] Napp-rzralias)r[findrr app_describer&rwr-s r/get_app_from_pathr1es E ??6 "} d{TYYs^a'()OTYYs^$xx$$T$77 ?? A**B?Bcd}|jdsd|z}d|vr+||jddzd}|d|jd} tjj ||S#tj $rYywxYw)a :param path: A string to attempt to resolve to a global workflow object :type path: string :returns: The describe hash of the global workflow object if found, or None otherwise :rtype: dict or None This method parses a string that is expected to perhaps refer to a global workflow object. If found, its describe hash will be returned. For more information on the contents of this hash, see the API documentation. [TODO: external link here] Nglobalworkflow-rzrr,)r[r.rrglobal_workflow_describer&r0s r/get_global_workflow_from_pathr6}s E ??, - 4' d{TYYs^a'()OTYYs^$xx00U0CC ??r2c|jdr t|S|jdr t|St|}|s t|}|S)Nr+r4)r[r1r6rwrs r/get_global_exec_from_pathr9sO v && * +,T22 T "D ,T2 KrGcBt|}|td|zdz|S)a :param path: A string which is supposed to identify an app :type path: string :returns: The describe hash of the app object :raises: :exc:`ResolutionError` if it cannot be found *path* is expected to have one of the following forms: - hash ID, e.g. "app-B8GZ8bQ0xky1PKY6FjGQ000J" - named ID, e.g. "app-myapp" - named ID with alias (version or tag), e.g. "app-myapp/1.2.0" rz," could not be resolved to an accessible app)r1r@r8s r/ resolve_appr;s/ T "D |047:hhii rGcBt|}|td|zdz|S)a :param path: A string which is supposed to identify a global workflow :type path: string :returns: The describe hash of the global workflow object :raises: :exc:`ResolutionError` if it cannot be found *path* is expected to have one of the following forms: - hash ID, e.g. "globalworkflow-F85Z6bQ0xku1PKY6FjGQ011J" - named ID, e.g. "globalworkflow-myworkflow" - named ID with alias (version or tag), e.g. "globalworkflow-myworkflow/1.2.0" rz8" could not be resolved to an accessible global workflow)r6r@r8s r/resolve_global_workflowr=s/ ) .D |047:ttuu rGc t|s|rd|vrtdj|jdr t |S|jdr t |St |}|s t|}|td|zdz|S)aD :param path: A string which is supposed to identify a global executable (app or workflow) :type path: string :param is_version_required: If set to True, the path has to specify a specific version/alias, e.g. "myapp/1.0.0" :type is_version_required: boolean :returns: The describe hash of the global executable object (app or workflow) :raises: :exc:`ResolutionError` if it cannot be found *path* is expected to have one of the following forms: - hash ID, e.g. "globalworkflow-F85Z6bQ0xku1PKY6FjGQ011J", "app-FBZ3f200yfzkKYyp9JkFVQ97" - named ID, e.g. "app-myapp", "globalworkflow-myworkflow" - named ID with alias (version or tag), e.g. "myapp/1.2.0", "myworkflow/1.2.0" - named ID with prefix and with alias (version or tag), e.g. "app-myapp/1.2.0", "globalworkflow-myworkflow/1.2.0" rzz(Version is required, e.g. "myexec/1.0.0"r+r4rzL" could not be resolved to an accessible global executable (app or workflow))rSr@rr[r;r=r1r6)rwis_version_requiredrs r/resolve_global_executabler@s T?2s$HOOQRR v4  * +&t,, T "D ,T2 |  %(v vx x KrGcd}d}d}d}||s t|}|" t|ddgdd\}}}d} |(|D cgc] } | | s | }} t|d k(rd}| t|d k(r|||d d }|S| | ||}|S|tstd |zt d |z|D cgc]} t | d } } |,| jd j|d|d|dt| } | t|kr||| d }|S||}|Std|z||}|Scc} w#t$r|d}YwxYwcc} w)NcT|ddk(rtj|d|dS|ddk(rtj|dS|ddk(rtj|d|dS|dd k(rtj|dSt d j |d) Nclassappletrr|)r|app)dxidworkflowglobalworkflowz(The executable class {} is not supported)rDXAppletDXApp DXWorkflowDXGlobalWorkflowrr)rs r/get_handler_from_descz/get_exec_handler..get_handler_from_descs =H $==dT)_E E ']e #::4:. . ']j (??4:tIG G ']. .((d4j9 9DKKDQXMZ[ [rGcJ|jdxs|jdS)Nz workflow-zapplet-)r[rvs r/"path_starts_with_non_global_prefixz.path_starts_with_non_global_prefixs{+Ity/IIrGrF)rDrecordrGvisible)rrrr c|dddvS)NrrC)rDrGrM)r*s r/is_applet_or_workflowz/get_exec_handler..is_applet_or_workflow s* g.2HHIrGrrrz)Found multiple executables with the path z"{prefix}-{name}, version {version}rCrversion)r+rrTzNo matches found for ) r9r rr@r rrr4rr0)rwr-handlerrMrOglobal_exec_desc_project _folderpathentity_resultsrSr*rchoice_descriptionsr)s r/get_exec_handlerr\sG \J  -d 34T: } &4I$S[Y^[{U^ 5` 1Hk>  J)-;!X?TUV?W!!X!X~&!+%)N  %#n*=*BGWG_+N1,=j,IJG2 N1 #(8(D+,<=G. N- '"%&QTX&XYY =D EIW"XA=:#?"X "X+#**8??/8-f5 0 ;@=> -.FN++0v0Fz0RS N 00@A N""9D"@A A'(89 NG"Y &'!%  &#Ys/E E E E=E& EE#"E#ct|dd|\}}}|&t|s|dk7r|dk7rtd|zdz|||fS)a3 :param path: Path to resolve :type path: string :param all_matching_results: Whether to return a list of all matching results :type all_matching_results: boolean A thin wrapper over :meth:`resolve_existing_path` which throws an error if the path does not look like a project and doesn't match a data object path. Returns either a list of results or a single result (depending on how many is expected; if only one, then an interactive picking of a choice will be initiated if input is a tty, or else throw an error). rT)rr'rNrzzCould not resolve "z" to an existing data object or to only a project; if you were attempting to refer to a project by name, please append a colon ":" to indicate that it is a project.)r r\r@)rwall_matching_resultsr|rrYs r/resolve_to_objects_or_projectr_2sr +@IQKOI]+_'GZod&;  *"3!"7$">#a#ab b J ..rGc~ td|}|dk(rtd|d}||dzd}||fS#tdxYw)N=rrrzSAn input was found that did not conform to the syntax: -i=)rrr )keyeqval first_eq_posrr.s r/parse_input_keyvalrdPs`p,S(; 2  sH-a0)*+e}pnoos,/ <)NNNFF)FrB)FF)NFT)NTF)FFT)Teither)NTNFTFTre)J__doc__ __future__rrrrresysrrrrrcompatr clir r r%r rr0rr>rr@compilerVrOrkrrrSrWr\r^r`rbrirlrprsrxrrrrrrrrorrrrrurrrrrrrrr rr1r6r9r;r=r@r\r_rdrMrGr/rls"SR #+,C+J,/$#@g2::XYrzzGH BCrzzST 26d?@;S4`2"C(!\]^_68:%