o miPu @sddlZddlmZmZmZmZddlZddlmZddl m Z m Z m Z m Z mZeeZidgdgdejddddgd d gd gd ejejddddgd d gdgdejddgd dgdgdejejddgd dgdgdejejejddgd dgdgdejddgd dgdgdejddgd dgdgdejejejgd dgdd d!gejejgd d"gd#d$d%gddgd d&gd#d$d%gddgd d'gd#d$d%gddgd d(d)d*gd$gdgd d+d)d*gd$gdgd d,gd#d$d%gddgd d-gd#d$d%gddgd d.gd#d$d%gddgd id/gd#d$d%gddgd d0gd#d$d%gddgd d1gd#d$d%gddgd d2gd#d$d%gddgd d3gd#d$d%gddgd d4gdgdejddgd d5gdgdejddgd d6gdgdejddgd d7gdgdejddgd d8gd9gd:gd;dgd?d d@gejdgdd}|jdvr4t|jdd}t|jdd}d|||d|||}nt|jdd}|||}Wn tyPd }Ynwtd |jtj||d id St|jdd krzt|jdd}|||}Wn tyd }Ynwtd |jtjt |d|did St|jddkrzt|jdd}|||}Wn tyd }Ynwtd|jtj |d|did Sd S)afLog the generated images, audio, video, etc. from the Diffusion Pipeline's response along with an optional caption to a media panel in the run. Args: image: (Any) The generated images, audio, video, etc. from the Diffusion Pipeline's response. loggable_kwarg_chunks: (List) Loggable chunks of kwargs. rD)rprqrrrkz Prompt-1: z Prompt-2: NzGenerated-Image/Pipeline-Call-)captionrCGenerated-Video/Pipeline-Call-rGrrJzGenerated-Audio/Pipeline-Call->) sample_rater) rwrsindex ValueErrorrxlogrtImageVideor Audio)r|r rrr prompt_index prompt2_indexr}r}r~ log_medias "       z-DiffusersMultiModalPipelineResolver.log_mediacCsg}t|jd}t|D]%\}}||dur'|||dur#||ndq |||||q dt|jvrC|t|n)t|jddkrY|tjt|ddnt|jddkrl|tj|d d |j j |dS) a!Populate the row of the `wandb.Table`. Args: image: (Any) The generated images, audio, video, etc. from the Diffusion Pipeline's response. loggable_kwarg_chunks: (List) Loggable chunks of kwargs. idx: (int) Chunk index. rNrrDrCrrGrJr)r) rwrs enumerateappendrxrrr rr{add_data)r|r rr table_row kwarg_actions column_idxloggable_kwarg_chunkr}r}r~add_data_to_table s.     z5DiffusersMultiModalPipelineResolver.add_data_to_tablerc s`||}|jdkrddkrt||j}|jdvr]t||jdkd}td|jtj|dd d it |jd fd d t t D}| tj|dd|j j|nJt |jd g}D]}| t|trw|n|gqht|t |d}t t |dD]} || D]} || || || || qqd|j|j iS)aPrepare the loggable dictionary, which is the packed data as a dictionary for logging to wandb, None if an exception occurred. Args: pipeline: (Any) The Diffusion Pipeline. response: (wandb.sdk.integration_utils.auto_logging.Response) The response from the request. kwargs: (Dict[str, Any]) Dictionary of keyword arguments. Returns: Packed data as a dictionary for logging to wandb, None if an exception occurred. rp output_typelatent)rarbrb) normalizerrrrrcsg|]}|qSr}r}).0rrloggable_kwarg_idsr}r~ Vs zMDiffusersMultiModalPipelineResolver.prepare_loggable_dict..rrzResult-Table/Pipeline-Call-)rrsr rr rxrrtrrwrangelenrr{r isinstancelistrrr) r|rrrrrCrrloggable_kwarg_idrr r}rr~r1sP            z9DiffusersMultiModalPipelineResolver.prepare_loggable_dict)__name__ __module__ __qualname____doc__strintrrrrrfloatrrrrrrr}r}r}r~rrQsH    @J '  rr)loggingtypingrrrrrx(wandb.sdk.integration_utils.auto_loggingrutilsrr r r r getLoggerrrrrwrrr}r}r}r~s   ' 1<N \ jx  #(-27<AF P Z d ny%.7@ JU _ir | "+ 5>HQ]o   C