gddlZddlmZdZ ddlmZn #e$rYnwxYwGddeZ dd lmZm Z dS#e$re edfd Zefd Z YdSwxYw) N)methodc(t||||S)zS setattr() and return `ob`. Different order used to allow easier partial usage. )setattr)attrvalobs Q/granary/edev/quantum/lib/python3.11/site-packages/postgresql/python/functools.pyrsetattrr s  T3 )r cReZdZdZ ddlmZeeZ[dS#e$rYdSwxYw) Compositionc&|D] }||}|S)N)selfrxs r __call__zComposition.__call__s%   aqtt11 (r r )composeN)__name__ __module__ __qualname__rport.optimizedrr ImportErrorrr r rrsf   &&&&&& VG__( gg$$s &&r) process_tuple process_chunkc||}|||krtd|||fzdg|z} t|D]!}||}| |||||<"n)#t$rtjd}YnwxYw||||||t d||S)z Call each item in `procs` with the corresponding item in `tup` returning the result as `type`. If an item in `tup` is `None`, don't process it. If a give transformation failes, call the given exception_handler. z5inconsistent items, %d processors and %d items in rowNrz/process_tuple exception handler failed to raise) TypeErrorrange Exceptionsysexc_info RuntimeError) procstupexception_handlerlentuplecauseirr s r rr%s c%jj!SXX]] ;C>    fqj! !HHq QB z 58B<>! 555 UE3*** G H HH q/s1A11#BBc(fd|DS)Nc*g|]}|Srr).0rfailrr%s r z!process_chunk..Es' 6 6 6A--q$ ' ' 6 6 6r r)r%tupcr/rs` ``r rrDs% 6 6 6 6 6 6 6 6 66r ) r"decorlibrr rrr)rrrr(rr r r3s    &&&&&&&     %   $7::::::::::!7!7!78;UTX>7D7777777A!7s:AA