id.UddlmZddlZddlZddlmZddlmZmZddl m Z m Z ddl Z ddl mZddlmZddlmZdd lmZdd lmZmZ ddlZn #e$rdZYnwxYw dd lmZn #e$rdZYnwxYwe rdd lmZdad ed< d#d$dZ d%dZ!d&dZ" d#d'd"Z#dS)() annotationsN) defaultdict)IterableSequence) TYPE_CHECKINGAny) reporters)_augment_sys_path)Message)FileItem) LinterStats merge_stats)ProcessPoolExecutor)PyLinterzPyLinter | None_worker_linterlinterbytesextra_packages_pathsSequence[str] | NonereturnNonectj|att jt|rt|dSdS)zFunction called to initialize a worker for a Process within a concurrent Pool. :param linter: A linter-class (PyLinter) instance pickled with dill :param extra_packages_paths: Extra entries to be added to sys.path N)dillloadsr set_reporterr CollectingReporteropenr )rrs I/opt/cloudlinux/venv/lib/python3.11/site-packages/pylint/lint/parallel.py_worker_initializer'skZ''N  < > >???0./////00 file_itemr etuple[int, str | None, str, str | None, list[Message], LinterStats, int, defaultdict[str, list[Any]]]ctstdtt|t t }tD]8}|}| ||j |9tj j }tj tj tjdt t#t%jtj |jtjj|tjtj|fS)Nz!Worker linter not yet initialisedzIn pylint 3.0 the current_name attribute of the linter object should be a string. If unknown it should be initialized as an empty string.)r RuntimeErrorrcheck_single_file_itemrlist get_checkers get_map_datanameappendreportermessagesreset current_namewarningswarnDeprecationWarningidmultiprocessingcurrent_processfilepath file_state base_namestats msg_status)r!mapreduce_datacheckerdatamsgss r_worker_check_single_filer><s, @>???)))444 &&N!..0066##%%   7< ( / / 5 5 5  " +D!!###"* J      ? * , ,--#!+ !  r rall_mapreduce_data3defaultdict[int, list[defaultdict[str, list[Any]]]]cVtt}|D]<}|D]7}|D] \}}|||!8=|}|D],}|j|vr!||||j-dS)zJMerges map/reduce data across workers, invoking relevant APIs on checkers.N)rr&valuesitemsextendr'r)reduce_map_data) rr?collated_map_reduce_data linter_datarun_data checker_namer<original_checkersr;s r_merge_mapreduce_datarKis=Hr6r7_is_base_filestateset_current_moduler+handle_messager*r9rKrr8)rrLrNrrRexecutor all_statsr? worker_idxmodule file_pathr7r,r8r9r:msgs rcheck_parallelras#1EK kTZ=O=O&"4555 ~ 9::FLLLsCD--D14D1)N)rrrrrr)r!r rr")rrr?r@rr) rrrLrMrNrOrrrr)$ __future__rrTr/ collectionsrcollections.abcrrtypingrrrpylintr pylint.lint.utilsr pylint.messager pylint.typingr pylint.utilsr rr3 ImportErrorconcurrent.futuresr pylint.lintrr__annotations__rr>rKrar rrps #""""""######........%%%%%%%% //////""""""""""""11111111OOO6666666%$$$$$$#'&&&&AE00000*****ZTTTT826 1;1;1;1;1;1;1;s$ AAAA%%A/.A/