File: //home/arjun/projects/env/lib/python3.10/site-packages/flake8/__pycache__/checker.cpython-310.pyc
o
%we5X � @ s� U d Z ddlmZ ddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl m
Z
ddl mZ ddl mZ ddl mZ ddl mZ dd l mZ dd
lmZ dd lmZ dd lmZ dd
lmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl m Z ddl!m"Z" eee#e$e$e#ee# f Z%e�&e'�Z(ej)hZ*de+d< de+d< ej,d7d d ��Z-d8d!d"�Z.d9d&d'�Z/G d(d)� d)�Z0G d*d+� d+�Z1d:d/d0�Z2d;d5d6�Z3dS )<z$Checker Manager and Checker classes.� )� annotationsN)�Any)� Generator)�List)�Optional)�Sequence)�Tuple)�defaults)�
exceptions)� processor)�utils)�
FSTRING_START)� expand_paths)�
parse_args)�Checkers)� LoadedPlugin)�StyleGuideManagerr � _mp_plugins�argparse.Namespace� _mp_options�plugins�options�return�Generator[None, None, None]c c s$ � | |a azd V W b bd S b bw �N)r r )r r � r �G/home/arjun/projects/env/lib/python3.10/site-packages/flake8/checker.py� _mp_prefork5 s
�
r �argv�
Sequence[str]�Nonec C sL t � t jt j� zttf W d S ty% t| �\}}|j|aaY d S w r )�signal�SIGINT�SIG_IGNr r � NameErrorr �checkers)r r r r r r �_mp_initB s �r& �filename�str�#tuple[str, Results, dict[str, int]]c C s t | ttd��� S )N�r' r r )� FileCheckerr r �
run_checks�r' r r r �_mp_runO s
��r. c @ st e Zd ZdZd%d
d �Zd&d d
�Zd'dd�Zd(dd�Zd)dd�Zd&dd�Z d&d d �Z
d&d d �Z d&d d!�Z d&d"d#�Z
d$S )*�ManageraR Manage the parallelism and checker instances for each plugin and file.
This class will be responsible for the following:
- Determining the parallelism of Flake8, e.g.:
* Do we use :mod:`multiprocessing` or is it unavailable?
* Do we automatically decide on the number of jobs to use or did the
user provide that?
- Falling back to a serial way of processing files if we run into an
OSError related to :mod:`multiprocessing`
- Organizing the results of each checker so we can group the output
together and make our output deterministic.
� style_guider r r r r r r c C sV || _ |j| _|| _| �� | _ddddd�| _g | jj�| jj�R | _|| _g | _ dS )z Initialize our Manager instance.r )�files�
logical lines�physical lines�tokensN)
r0 r r �
_job_count�jobs�
statistics�exclude�extend_excluder �results)�selfr0 r r r r r �__init__h s
�
zManager.__init__c C sP | j D ]\}}}tjD ]
}| j| || 7 < q q| jd t| j�7 < d S )Nr1 )r: r �STATISTIC_NAMESr7 �len� filenames)r; �_r7 � statisticr r r �_process_statistics} s
� zManager._process_statistics�intc C sP t �| jj�rt�d� dS | jj}|jr%zt� � W S t
y$ Y dS w |j S )Nz]The --jobs option is not compatible with supplying input using - . Ignoring --jobs arguments.r ) r �is_using_stdinr r? �LOG�warningr6 �is_auto�multiprocessing� cpu_count�NotImplementedError�n_jobs)r; r6 r r r r5 � s �
�zManager._job_countr' r( r: �Resultsc
C s< | j }d}|D ]\}}}}} ||j|||||| d�7 }q|S )Nr )�coder' � line_number�
column_number�text�
physical_line)r0 � handle_error)
r; r' r: r0 �reported_results_count�
error_coderN �columnrP rQ r r r �_handle_results� s
�zManager._handle_results�tuple[int, int]c C s� d }}| j jt�d�d� | j D ]3\}}}|jt�dd�d� | j�|�� || �||�7 }W d � n1 s9w Y |t|�7 }q||fS )a Report all of the errors found in the managed file checkers.
This iterates over each of the checkers and reports the errors sorted
by line number.
:returns:
A tuple of the total results found and the results reported.
r )�key� � N)r: �sort�operator�
itemgetterr0 �processing_filerV r> )r; �results_reported�
results_foundr' r: r@ r r r �report� s �zManager.reportc C s� t | j| j�� t| j| j�}W d � n1 sw Y |du r(| �� dS d}z#t|�t | j
��| _ |� � |�
� d}W |sL|�� |�
� dS dS |sY|�� |�
� w w )z Run the checkers in parallel.NFT)r r r �_try_initialize_processpoolr6 r �
run_serial�list�imap_unorderedr. r? r: �close�join� terminate)r; �pool� pool_closedr r r � run_parallel� s& � �
�zManager.run_parallelc s � fdd�� j D �� _dS )zRun the checkers in serial.c s" g | ]
}t |� j� jd ��� �qS )r* )r+ r r r, )�.0r' �r; r r �
<listcomp>� s ���z&Manager.run_serial.<locals>.<listcomp>N)r? r: rm r rm r rc � s
�zManager.run_serialc C sX z| j dkrt| j�dkr| �� W dS | �� W dS ty+ t�d� t� d��w )a# Run all the checkers.
This will intelligently decide whether to run the checks in parallel
or whether to run them in serial.
If running the checks in parallel causes a problem (e.g.,
:issue:`117`) this also implements fallback to serial processing.
rY z"Flake8 was interrupted by the userz Early quit while running checksN)
r6 r> r? rk rc �KeyboardInterruptrE rF r
� EarlyQuitrm r r r �run� s
�z Manager.runc C s2 t �d� tt| jj| jj| jj| jd��| _dS )z�Start checking files.
:param paths:
Path names to check. This is passed directly to
:meth:`~Manager.make_checkers`.
zMaking checkers)�paths�stdin_display_name�filename_patternsr8 N) rE �info�tupler r r? rs r' r8 rm r r r �start� s
�
�z
Manager.startc C s | � � dS )zStop checking files.N)rB rm r r r �stop � z Manager.stopN)r0 r r r r r r r �r r )r rC )r' r( r: rL r rC )r rW )�__name__�
__module__� __qualname__�__doc__r< rB r5 rV ra rk rc rq rw rx r r r r r/ U s
r/ c @ s� e Zd ZdZd9d
d �Zd:d d
�Zd;dd�Zd<dd�Zd=d d �Ze d>d"d#��Z
d?d$d%�Z d?d&d'�Z d@d)d*�Z
d?d+d,�ZdAd.d/�ZdBd1d2�ZdCd6d7�Zd8S )Dr+ z;Manage running checks for a file and aggregate the results.r' r( r r r r r r c C sx || _ || _|| _g | _dddd�| _| �� | _|| _d| _| jdur:| jj| _| j� � | _t
| jj �| jd< dS dS )z Initialize our file checker.r )r4 r2 r3 FNr3 ) r r' r r: r7 �_make_processorr � display_name�should_process�should_ignore_filer> �lines)r; r' r r r r r r< s �
�zFileChecker.__init__c C s d| j � �S )z)Provide helpful debugging representation.zFileChecker for r- rm r r r �__repr__$ ry zFileChecker.__repr__� processor.FileProcessor | Nonec C sZ z t �| j| j�W S ty, } z| �dddt|�j� d|� �� W Y d }~d S d }~ww )N�E902r �: )r �
FileProcessorr' r �OSErrorra �typer{ )r; �er r r r ( s ��zFileChecker._make_processorrT �
str | NonerN rC rU rP c C sX |du r |� dd�\}}t| d�r | jdur | j�|�}nd}| j�|||||f� |S )z2Report an error by storing it in the results list.N� rY r )�split�hasattrr �
noqa_line_forr: �append)r; rT rN rU rP �liner r r ra 5 s zFileChecker.report�pluginr � argumentsr c
K s� | j dus
J | j��z
| j �|j|�}W n ty( } ztj|j|d��d}~ww z |jdi |�|��W S t yS } zt
j d|jdd� tj | j|j|d��d}~ww )z!Run the check in a single plugin.N)� plugin_name� exceptionz(Plugin %s raised an unexpected exceptionT)�exc_info)r' r� r� r )
r r' �keyword_arguments_for�
parameters�AttributeErrorr
� PluginRequestedUnknownParametersr� �obj� ExceptionrE �critical�PluginExecutionFailed)r; r� r� �params�ae�all_excr r r � run_checkJ s4 ��������zFileChecker.run_checkr� r� rW c
C s t | j�dkr#| jd r#t | jd �dkr#| jd }|dd� \}}n&t| tj�rCt | j�dkrCt | jd �dkrCd}| jd \}}nd}d\}}|dkr�|r�t| t�r�t |�dkr�d}d}|d }|d ur�|�d��d�}t |�d }|d }t |�} || kr�| }||8 }||8 }||fS ) NrY rZ � r )rY r r � �
)r> �args�
isinstance�tokenize�
TokenError� SyntaxError�rstripr� )
r� �token�rowrU �
column_offset�
row_offsetrQ r� � logical_line�logical_line_lengthr r r �_extract_syntax_informationc sB �
��� z'FileChecker._extract_syntax_informationc C s� | j dus
J | j��| j �� }| jjD ]-}| j||d�}z|�� }W n ty- |}Y nw |D ]\}}}}| jd|||d� q0qdS )z1Run all checks expecting an abstract syntax tree.N)�tree�rT rN rU rP ) r r' � build_astr r� r� rq r� ra ) r; �astr� �checker�runnerrN �offsetrP r@ r r r �run_ast_checks� s$
����zFileChecker.run_ast_checksc
C s� | j dusJ �| j �� \}}}|sdS | j �|� t�d|�� � | jjD ]:}| j �|� | j ||d�p5d}|D ]&\}}t
||�\}} || krMdkrUn nt� d|� | j d|| |d� q8q%| j �
� dS )z(Run all checks expecting a logical line.NzLogical line: "%s")r� r r z#position of error out of bounds: %sr� )r �build_logical_line� update_staterE �debugr� r r� �update_checker_state_forr� � find_offsetrF ra �next_logical_line)
r; �commentsr� �mappingr� r: r� rP rN r� r r r �run_logical_checks� s* �� z FileChecker.run_logical_checksrQ c
C s� | j dusJ �| jjD ]C}| j �|� | j||d�}|durNd}z|d }W n ttfy1 Y nw t|t�r:|f}|D ]}|\}}| j d| j j
||d� q<q dS )zoRun all checks for a given physical line.
A single physical check may return multiple errors.
N)rQ r r� ) r r rQ r� r� �
IndexError� TypeErrorr� rC ra rN )r; rQ r� �resultr� �
result_singlerP r r r �run_physical_checks� s. �
���z FileChecker.run_physical_checksc C s� | j dusJ �d}| j}| j }d}|�� D ]6}|d d7 < | �||� |dd� \}}|tjkr9t �||�}n|dkrGt �|�rG| �|� |d }q|j r]| �
|j d � | � � dS dS ) z�Process tokens and trigger checks.
Instead of using this directly, you should use
:meth:`flake8.checker.FileChecker.run_checks`.
Nr � r4 rY rZ r� ���)
r r7 �generate_tokens�check_physical_eolr� �OP�count_parentheses�token_is_newline�handle_newliner4 r� r� r� )r; �parensr7 �file_processor�
prev_physicalr� �
token_typerP r r r �process_tokens� s&
�zFileChecker.process_tokensr) c C s� | j du s| js| j| j| jfS z
| �� | �� W nA ttj fy[ } z2t
|tj �r-dnd}| � |�\}}| � |||t
|�j� d|jd � �� | j| j| jfW Y d}~S d}~ww | j jd }|| jd< | j| j| jfS )z Run checks against the file.Nr� �E999r� r r2 )r r� r� r: r7 r� r� r� r� r� r� r� ra r� r{ r� )r; r� rM r� rU �
logical_linesr r r r, s & ��
zFileChecker.run_checksr� c C sb | j dusJ �|tjkr| �� | j �� dS t| j j�dkr+| j �� | j �� dS | �� dS )z3Handle the logic when encountering a newline token.NrY ) r r� �NEWLINEr� �reset_blank_beforer> r4 �visited_new_blank_line�delete_first_token)r; r� r r r r� s
zFileChecker.handle_newliner� �tokenize.TokenInfor� c C s� | j dusJ �|jtkr| j �|jd � dS t �|�r0|jdkr(| �|� dS | �|j� dS t �|�rC| j � |�D ] }| �|� q;dS dS )z@Run physical checks if and only if it is at the end of the line.Nr r� )
r r� r
�
fstring_startrw � is_eol_tokenr� r� �is_multiline_string�multiline_string)r; r� r� r� r r r r� & s
� z FileChecker.check_physical_eolN)r' r( r r r r r r )r r( )r r� )
rT r� rN rC rU rC rP r( r r( )r� r r� r r r )r� r� r rW rz )rQ r( r r )r r) )r� rC r r )r� r� r� r( r r )r{ r| r} r~ r< r� r ra r� � staticmethodr� r� r� r� r� r, r� r� r r r r r+ s
:
r+ � job_countrC � multiprocessing.pool.Pool | Nonec
C sZ z
t j| t|fd�W S ty# } z
|jtvr� W Y d}~dS d}~w ty, Y dS w )z@Return a new process pool instance if we are able to create one.)�initargsN)rH �Poolr& r� �errno�SERIAL_RETRY_ERRNOS� ImportError)r� r �errr r r rb F s
�� ��rb r� r� �processor._LogicalMappingrW c C sX t | t�r| S |D ]}|d }| |kr|d } nq d}d } }|d |d | | fS )z*Find the offset tuple for a single offset.r rY )r r )r� rv )r� r� r� � token_offset�positionr r r r� V s
�r� )r r r r r r )r r r r )r' r( r r) )r� rC r r r r� )r� rC r� r� r rW )4r~ �
__future__r �argparse�
contextlibr� �logging�multiprocessing.poolrH r\ r! r� �typingr r r r r r �flake8r r
r r �flake8._compatr
�flake8.discover_filesr �flake8.options.parse_argsr �flake8.plugins.finderr r �flake8.style_guider r( rC rL � getLoggerr{ rE �ENOSPCr� �__annotations__�contextmanagerr r& r. r/ r+ rb r� r r r r �<module> sV
�
4
@