cp D.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|atsJtt 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 /srv/buildsys-work-dir/castor/build_node/builder-2/WGSG1/unpkd_srcs/cloudlinux-venv-1.0.6/venv/lib/python3.11/site-packages/pylint/lint/parallel.py_worker_initializer'svZ''N > < > >???0./////00 file_itemr etuple[int, str | None, str, str | None, list[Message], LinterStats, int, defaultdict[str, list[Any]]]c tstdtt|t t }tD]8}|}| ||j |9tj j }ttj tjsJtj tjt#jdt&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_datanameappendreportermessages isinstancer rreset current_namewarningswarnDeprecationWarningidmultiprocessingcurrent_processfilepath file_state base_namestats msg_status)r!mapreduce_datacheckerdatamsgss r_worker_check_single_filer?<sH @>???)))444 &&N!..0066##%%   7< ( / / 5 5 5  " +D n-y/K L LLL L!!###"* 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_datarLis=H&"4555 ~ 9::FLLLsCD--D14D1)N)rrrrrr)r!r rr")rrr@rArr) rrrMrNrOrPrrrr)$ __future__rrUr0 collectionsrcollections.abcrrtypingrrrpylintr pylint.lint.utilsr pylint.messager pylint.typingr pylint.utilsr rr4 ImportErrorconcurrent.futuresr pylint.lintrr__annotations__rr?rLrbr rrqs #""""""######........%%%%%%%% //////""""""""""""11111111OOO6666666%$$$$$$#'&&&&AE00000*****ZTTTT826 1;1;1;1;1;1;1;s$ AAAA%%A/.A/