5i <ddlZddlZddlZddlmZmZdZdZdZ y)N)ImageRefFactoryImageRefFactoryErrorzcontainers.jsoncP|Dcgc] }t|}}|Dcgc]}|j}}t}g}|D]U}|j|vr|j |j j |j|jW|Scc}wcc}w)a :param image_refs: Image references extracted from run_nextaur_collect(). :type image_refs: Dict :returns: Array of dicts for bundledDepends attribute of the applet resources. Also saves images on the platform if not done that before. )r get_imageset identifierappendbundled_dependscopyadd) image_refsximage_factoriesimages seen_imagesr images ~/home/marpiech/ifpan-abm-pgxpred/analysis/marpiech-gwas-test/venv/lib/python3.12/site-packages/dxpy/nextflow/collect_images.pybundle_docker_imagesrs4>>aq)>O>%4 5akkm 5F 5%KO.   { *   " "5#8#8#=#=#? @ OOE,, - . ? 5s BB#cdj|}|rdj|nd}|rdj|nd}dj|||g}tj|ddd}tj j tst|jttd5}tj|jd d } | s td  d d d | S#1swY SxYw) ab :param resources_dir: URL to the local(ized) NF pipeline in the app(let) resources. :type resources_dir: String :param profile: Custom Nextflow profile. More profiles can be provided by using comma separated string (without whitespaces). :type profile: str :param nextflow_pipeline_params: Custom Nextflow pipeline parameters :type nextflow_pipeline_params: string :returns: Dict. Image references in the form of "process": String. Name of the process/task "repository": String. Repository (host) prefix "image_name": String. Image base name "tag": String. Version tag "digest": String. Image digest "file_id": String. File ID if found on the platform "engine": String. Container engine. Runs nextaur:collect z)nextflow plugin nextaur:collect docker {}zpipelineParams={}z profile={} T)shellcapture_outputtextr processesNz0Could not extract processes from nextaur:collect)formatjoin subprocessrunospathexistsCONTAINERS_JSONrstdoutopenjsonloadget) resources_dirprofilenextflow_pipeline_paramsbase_cmdpipeline_params_arg profile_arg nextaur_cmdprocess json_filer s rrun_nextaur_collectr30s$;AA-PHRj-445MNpr29,%%g.rK((H&9;GHKnn[TPTUG 77>>/ *"7>>22 os #[yYYy)--k4@ &'YZ Z[  [ s 13C//C9) r'os.pathr!rdxpy.nextflow.ImageRefFactoryrrr$rr3rr8s"( O#(r7