
    Z ja7                         S SK JrJrJr  S SKJrJr  SSKJr  SSK	J
r
Jr  SSKJr   " S S\S	S
9rSr\ " S S\5      5       rS/rg)    )ProcessingKwargsProcessorMixinUnpack)PreTokenizedInput	TextInput   )BatchFeature)
ImageInputmake_flat_list_of_images)auto_docstringc                        \ rS rSrSSS00rSrg)Llama4ProcessorKwargs   text_kwargspadding_sideleft N)__name__
__module____qualname____firstlineno__	_defaults__static_attributes__r       }/root/GenerationalWealth/GenerationalWealth/venv/lib/python3.13/site-packages/transformers/models/llama4/processing_llama4.pyr   r      s    F
Ir   r   F)totala>  {{- bos_token }}
{%- if custom_tools is defined %}
    {%- set tools = custom_tools %}
{%- endif %}
{%- if not tools_in_user_message is defined %}
    {%- set tools_in_user_message = true %}
{%- endif %}
{%- if not date_string is defined %}
    {%- if strftime_now is defined %}
        {%- set date_string = strftime_now("%d %b %Y") %}
    {%- else %}
        {%- set date_string = "26 Jul 2024" %}
    {%- endif %}
{%- endif %}
{%- if not tools is defined %}
    {%- set tools = none %}
{%- endif %}

{#- This block extracts the system message, so we can slot it into the right place. #}
{%- if messages[0]['role'] == 'system' %}    
    {%- if messages[0]['content'] is string %}
        {%- set system_message = messages[0]['content']|trim %}
    {%- else %}
        {#- FIXME: The processor requires an array, always. #}
        {%- set system_message = messages[0]['content'][0]['text']|trim %}
    {%- endif %}
    {%- set messages = messages[1:] %}
    {%- set user_supplied_system_message = true %}
{%- else %}
    {%- set system_message = "" %}
    {%- set user_supplied_system_message = false %}
{%- endif %}

{#- System message if the user supplied one #}
{%- if user_supplied_system_message %}
    {{- "<|header_start|>system<|header_end|>

" }}
    {%- if tools is not none %}
        {{- "Environment: ipython
" }}
    {%- endif %}
    {%- if tools is not none and not tools_in_user_message %}
        {{- "You have access to the following functions. To call a function, please respond with JSON for a function call." }}
        {{- 'Respond in the format {"name": function name, "parameters": dictionary of argument name and its value}.' }}
        {{- "Do not use variables.

" }}
        {%- for t in tools %}
            {{- t | tojson(indent=4) }}
            {{- "

" }}
        {%- endfor %}
    {%- endif %}
    {{- system_message }}
    {{- "<|eot|>" }}
{%- endif %}

{#- Custom tools are passed in a user message with some extra guidance #}
{%- if tools_in_user_message and not tools is none %}
    {#- Extract the first user message so we can plug it in here #}
    {%- if messages | length != 0 %}
        {%- set first_user_message = messages[0]['content']|trim %}
        {%- set messages = messages[1:] %}
    {%- else %}
        {{- raise_exception("Cannot put tools in the first user message when there's no first user message!") }}
{%- endif %}
    {{- '<|header_start|>user<|header_end|>

' -}}
    {{- "Given the following functions, please respond with a JSON for a function call " }}
    {{- "with its proper arguments that best answers the given prompt.

" }}
    {{- 'Respond in the format {"name": function name, "parameters": dictionary of argument name and its value}.' }}
    {{- "Do not use variables.

" }}
    {%- for t in tools %}
        {{- t | tojson(indent=4) }}
        {{- "

" }}
    {%- endfor %}
    {{- first_user_message + "<|eot|>"}}
{%- endif %}

{%- for message in messages %}
    {%- if not (message.role == 'ipython' or message.role == 'tool' or 'tool_calls' in message) %}
    {{- '<|header_start|>' + message['role'] + '<|header_end|>

' }}
        {%- if message['content'] is string %}
            {{- message['content'] }}
        {%- else %}
            {%- for content in message['content'] %}
                {%- if content['type'] == 'image' %}
                    {{- '<|image|>' }}
                {%- elif content['type'] == 'text' %}
                    {{- content['text'] }}
                {%- endif %}
            {%- endfor %}
        {%- endif %}
        {{- "<|eot|>" }}
    {%- elif 'tool_calls' in message and message.tool_calls|length > 0 %}
       {{- '<|header_start|>assistant<|header_end|>

' -}}
       {{- '<|python_start|>' }}
        {%- if message['content'] is string %}
            {{- message['content'] }}
        {%- else %}
            {%- for content in message['content'] %}
                {%- if content['type'] == 'image' %}
                    {{- '<|image|>' }}
                {%- elif content['type'] == 'text' %}
                    {{- content['text'] }}
                {%- endif %}
            {%- endfor %}
        {%- endif %}
       {{- '<|python_end|>' }}
        {%- for tool_call in message.tool_calls %}
           {{- '{"name": "' + tool_call.function.name + '", ' }}
           {{- '"parameters": ' }}
           {{- tool_call.function.arguments | tojson }}
           {{- "}" }}
        {%- endfor %}
       {{- "<|eot|>" }}
    {%- elif message.role == "tool" or message.role == "ipython" %}
        {{- "<|header_start|>ipython<|header_end|>

" }}
        {%- if message.content is mapping or message.content is iterable %}
            {{- message.content | tojson }}
        {%- else %}
            {{- message.content }}
        {%- endif %}
        {{- "<|eot|>" }}
    {%- endif %}
{%- endfor %}
{%- if add_generation_prompt %}
    {{- '<|header_start|>assistant<|header_end|>

' }}
{%- endif %}
c                      ^  \ rS rSrSSSSSSSSSS	S
\4S\S\4U 4S jjjrS r\	  SS\
S-  S\\-  \\   -  \\   -  S-  S\\   S\4S jj5       rSrU =r$ )Llama4Processor#   N   g      ?	<|image|><|image_start|><|image_end|>	<|patch|><|tile_x_separator|><|tile_y_separator|>
patch_sizepixel_shuffle_ratioc                    > [         TU ]  XUS9  [        [        SUS-  -  5      5      U l        X0l        XPl        X`l        UR                  U R                  5      U l	        Xpl
        Xl        Xl        Xl        Xl        g)a  
patch_size (`int`, *optional*, defaults to 28):
    The size of image patches for tokenization.
pixel_shuffle_ratio (`float`, *optional*, defaults to `0.5`):
    The ratio used for pixel shuffling when processing images. This controls the downsampling factor
    applied to image patches. The actual downsampling ratio is calculated as `1 / (pixel_shuffle_ratio^2)`.
fake_image_token (`str`, *optional*, defaults to `"<|image|>"`):
    The placeholder token in the text that will be replaced with actual image tokens. This token serves
    as a marker indicating where images should be inserted in the text sequence.
image_token (`str`, *optional*, defaults to `"<|image|>"`):
    The token to be used to represent an image in the text.
start_of_image_token (`str`, *optional*, defaults to `"<|image_start|>"`):
    The special token that marks the beginning of an image sequence in the text. This token is prepended
    to image token sequences to delimit image boundaries.
end_of_image_token (`str`, *optional*, defaults to `"<|image_end|>"`):
    The special token that marks the end of an image sequence in the text. This token is appended to
    image token sequences to delimit image boundaries.
patch_token (`str`, *optional*, defaults to `"<|patch|>"`):
    The token used to represent individual image patches. Multiple patch tokens are used to represent
    the full image, with the number depending on the image size and patch configuration.
tile_x_separator_token (`str`, *optional*, defaults to `"<|tile_x_separator|>"`):
    The token used to separate tiles (patches) horizontally within an image. This token is inserted
    between patches in the same row when images are split into multiple tiles.
tile_y_separator_token (`str`, *optional*, defaults to `"<|tile_y_separator|>"`):
    The token used to separate tiles (patches) vertically within an image. This token is inserted
    between rows of patches when images are split into multiple tiles.
)chat_templateg      ?   N)super__init__introunddownsample_ratior'   fake_image_tokenimage_tokenconvert_tokens_to_idsimage_token_idstart_of_img_tokenend_of_img_tokenimg_patch_token
tile_tokentile_global_token)selfimage_processor	tokenizerr'   r(   r1   r2   start_of_image_tokenend_of_image_tokenpatch_tokentile_x_separator_tokentile_y_separator_tokenr*   kwargs	__class__s                 r   r-   Llama4Processor.__init__%   s|    V 	=Q #E#1Da1G*H$I J$ 0&'==d>N>NO"6 2*0!7r   c                     SnUu  pEXE-  S:  a@  [        U5       H1  n[        U5       H  nUSU-  -  nXuS-
  :  d  M  US-  nM     US-  nM3     US-  nUSU-  -  nUS-  nU$ )z
Create a structured string representation of image tokens

Args:
   num_patches: Number of patches in the image

Returns:
    String with appropriate image tokens
r"      r$   r%   r&   r!   r#   )range)r:   aspect_rationum_patches_per_chunk
img_stringratio_hratio_wyyxxs           r   _prompt_split_image#Llama4Processor._prompt_split_image^   s     '
'q Gn.B+0E"EEJaK'"&<<
 )
 44
 % 	k!
k$999
o%
r   imagestextrB   returnc                   ^  Uc  [        S5      eT R                  " [        4ST R                  R                  0UD6n[        U[        [        45      (       d  U/n0 nUGb  T R                  R                  U5      n[        U5      nT R                  " SSU0US   D6nUS   S   R                  SS u  pg[        UT R                  -  UT R                  -  -  T R                  -  5      nUR                  S	5      n	[!        U 4S
 jU 5       5      n
U
[#        U5      :w  a  [        SU
 S[#        U5       S35      eSn/ nU H  nUR%                  T R&                  5      nUS:X  a  UR)                  U5        M7  UR+                  T R&                  5      n/ n[-        U5       HI  u  nnUR)                  U5        UU:  d  M  T R/                  X   U5      nUS-  nUR)                  U5        MK     UR)                  SR1                  U5      5        M     U[#        U5      :w  a  [        S5      eUnUS   R                  SS5      nT R                  " U40 US   D6nT R3                  UUS/S9  [5        0 UEUEUS9$ )a  
Returns:
    [`BatchFeature`]: A [`BatchFeature`] with the following fields:

    - **input_ids** -- List of token ids to be fed to a model. Returned when `text` is not `None`.
    - **attention_mask** -- List of indices specifying which tokens should be attended to by the model (when
      `return_attention_mask=True` or if *"attention_mask"* is in `self.model_input_names` and if `text` is not
      `None`).
    - **pixel_values** -- Pixel values to be fed to a model. Returned when `images` is not `None`.
NzYou have to specify text.tokenizer_init_kwargsrQ   images_kwargspixel_valuesr   aspect_ratiosc              3   X   >#    U  H  oR                  TR                  5      v   M!     g 7f)N)countr1   ).0promptr:   s     r   	<genexpr>+Llama4Processor.__call__.<locals>.<genexpr>   s#     $\W[V\\$2G2G%H%HW[s   '*zFound z) placeholders across the batch, but have z flattened images.rF    zONumber of image placeholders in the prompt does not match the number of images.r   return_tensorsimage)
modalities)datatensor_typer   )
ValueError_merge_kwargsr   r<   init_kwargs
isinstancelisttupler;   fetch_imagesr   shaper.   r'   r0   popsumlenr[   r1   appendsplit	enumeraterO   join_check_special_mm_tokensr	   )r:   rQ   rR   rB   output_kwargsimage_inputsimage_heightimage_widthrI   rY   total_placeholdersimage_indexprocessed_textr]   placeholder_countprompt_splits
new_promptlocal_image_index
split_parttokens_for_this_imagera   text_inputss   `                     r   __call__Llama4Processor.__call__y   s   " <899**!
"&.."<"<
 
 $u..6D ))66v>F-f5F//`v`A_`L(4^(DQ(G(M(Mbc(R%L$'0[DOO5STX\XmXmm%! ),,_=M!$$\W[$\!\!S[0 /0 1  #F},>@ 
 KN$*LL1F1F$G!$)"))&1 &T-B-B C
5>}5M1%z%%j1(+<<040H0H)68M1- $q("))*?@ 6N %%bggj&9:! $ c&k) !rss!D&}599:JDQnnTJ]=-IJ%%dKWI%N!@K!@<!@n]]r   )
r0   r6   r1   r2   r4   r7   r'   r5   r9   r8   )NN)r   r   r   r   r*   r.   floatr-   rO   r   r
   r   r   rj   r   r   r	   r   r   __classcell__)rC   s   @r   r   r   #   s     %($.*55#78 	78
 #78 78r6  %)aeL^T!L^ ++d9o=EV@WWZ^^L^ ./	L^
 
L^ L^r   r   N)transformers.processing_utilsr   r   r   $transformers.tokenization_utils_baser   r   image_processing_utilsr	   image_utilsr
   r   utilsr   r   r*   r   __all__r   r   r   <module>r      s^     S R M 2 ? #,E  ]P b^n b^ b^J 
r   