iAdZGddeZy)zP PassportEye::Util: Pipeline utility Author: Konstantin Tretyakov License: MIT cDeZdZdZdZd dZdZd dZdZdZ d Z d Z y) Pipelinea The computation performed in order to extract the information from an image is essentially a list of steps of various complexity, where each step uses results of the previous steps and introduces its own results. Although this is nothing more than a standard sequential program, it seems to be somewhat more convenient sometimes to regard it as a "pipeline" consisting of pluggable "components", where each component explicitly specifies what inputs it needs and what outputs it produces, and the workflow engine wires up the inputs to the outputs. This class offers provides a simple implementation of such a pipeline. It keeps track of a dictionary of values that were already computed, a dictionary of "components" which know how to compute other values, and routes item accesses to computations automatically. >>> a = Pipeline() >>> a.add_component('1', lambda: 1, ['a'], []) >>> a.add_component('2', lambda: 2, ['b'], []) >>> a.add_component('s,d', lambda x,y: (x+y, x-y), ['c', 'd'], ['a', 'b']) >>> a.add_component('sd', lambda x,y: (x+y, x-y), ['e'], ['a', 'b']) >>> a['c'] 3 >>> a['d'] -1 >>> a['e'] (3, -1) >>> a.replace_component('1', lambda: 2, ['a'], []) >>> a['e'] (4, 0) >>> a['d'] 0 ct|_t|_t|_t|_t|_|j|jd<||jd<y)N__data__ __pipeline__)dictdata componentsprovidesdepends whoprovides)selfs ~/var/www/ITT-ServiceAPI-Services/ITT-Document-Scan/mrzscanner/mrzenv/lib/python3.12/site-packages/passporteye/util/pipeline.py__init__zPipeline.__init__*sPF & v 6 $  *$( .!Nc|xs t|dg}|xs t|dg}|D]}||jvstd|z||j|<||j|<||j |<|D]}||j|<y)a' Add a given callable to a list of components. The provides and depends are lists of strings, specifying what keys the component computes and what keys it requires to be present. If those are not given, the callable must have fields __provides__ and __depends__. __provides__ __depends__z-There is already a component that provides %sN)getattrr Exceptionr r r )r namecallabler r ps r add_componentzPipeline.add_component3s DwxDAWX}bA UAD$$$ ORS STT U' d$ T ( 'A"&D  Q  'rc||jvrtd|z|j|=|j|=|j|D] }|j|=|j |"|j|=y)zxRemoves an existing component with a given name, invalidating all the values computed by the previous component.zNo component named %sN)r rr r r invalidate)r rrs rremove_componentzPipeline.remove_componentDsy t &3d:; ; OOD ! LL t$ A  # OOA   MM$ rcN|j||j||||y)zChanges an existing component with a given name, invalidating all the values computed by the previous component and its successors.N)rr)r rrr r s rreplace_componentzPipeline.replace_componentPs& d# 48W=rc||jvry|j|=|jD]9}||j|vs|j|D]}|j |;y)zORemove the given data item along with all items that depend on it in the graph.N)rr r r r)r keycnamedownstream_keys rrzPipeline.invalidateVsf dii   IIcN__ 4Edll5))&*mmE&:4NOON34 4rc"||j|<yN)r)r r values r __setitem__zPipeline.__setitem__bs #rcB|j||j|Sr$)_computer)r r s r __getitem__zPipeline.__getitem__es cyy~rc||jvr|j|}|j|D]}|j||j|Dcgc]}|j|}}|j||}t |j |dk(r ||j|j |d<yt|j ||D]\}}||j|<yycc}w)N)rr r r(r lenr zip)r r r!dinputsresultskvs rr(zPipeline._computeis dii $$S)E\\%( ! a  !,0LL,?@qdiil@F@,dooe,f5G4=='(A-5< $--.q12 e 4g>%DAq#$DIIaL% AsC+)NN) __name__ __module__ __qualname____doc__rrrrrr&r)r(rrrr s0@)'"  > 4 %rrN)r7objectrr8rrr:sk%vk%r