Ch SrSSKrSSKrSSKJr SSKJrJrJrJ r J r J r J r SSK Jr SSKJrJr \R("S\S S 9 \4S jrS r\\4S jrSSjr\\4SjrSSjrg!\a SSKJrJrJrJrJ r J r J r J r NXf=f)z*serialization utilities for apply messagesN)chain) CannedObjectcan can_sequenceistypesequence_typesuncanuncan_sequence)PICKLE_PROTOCOL)r rrrrrr r ) MAX_BYTES MAX_ITEMSzHipykernel.serialize is deprecated. It has moved to ipyparallel.serialize) stacklevelc\/n[U[5(aUR(a[UR5Hjup4[ U5U:a"SURU'UR U5 M6[U[ 5(dMMUR5URU'Ml U$)z/extract buffers larger than a certain thresholdN) isinstancerbuffers enumeratelenappend memoryviewtobytes)obj thresholdribufs fC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\ipykernel/serialize.py_extract_buffersr0s}G#|$$ ,FA3x)#!% As#C,,!$ A- Nc[U[5(aTUR(aB[UR5H(up#UbM UR S5URU'M* ggg)zrestore buffers extracted byNr)rrrrpop)rrrrs r_restore_buffersr!@sL#|$$ ,FA{!(Q A-*5$rc/n[U[5(a>[U5U:a/[U5nUHnUR [ XQ55 M O[U[ 5(aO[U5U:a@0n[U5H.n[X5nUR [ XQ55 XTU'M0 O%[U5nUR [ XA55 URS[R"U[55 U$)aSerialize an object into a list of sendable buffers. Parameters ---------- obj : object The object to be serialized buffer_threshold : int The threshold (in bytes) for pulling out data buffers to avoid pickling them. item_threshold : int The maximum number of items over which canning will iterate. Containers (lists, dicts) larger than this will be pickled without introspection. Returns ------- [bufs] : list of buffers representing the serialized object. r) rrrrextendrdictsortedrinsertpickledumpsr )rbuffer_thresholditem_thresholdrcobjcks rserialize_objectr.Hs&G c>""s3x.'@C A NN+A@ A T  s3x.8ACF A NN+A@ AG 3x'?@ NN1fll49: Nrc[U5nURS5n[R"U5n[ U[ 5(a5[ U5[:a"UHn[XR5 M [XA5nXb4$[ U[5(aF[ U5[:a30n[U5HnXGn[XR5 [XQ5Xg'M! Xb4$[XB5 [XA5nXb4$)areconstruct an object serialized by serialize_object from data buffers. Parameters ---------- buffers : list of buffers/bytes g : globals to be used when uncanning Returns ------- (newobj, bufs) : unpacked object, and the list of remaining unused buffers. r) listr r'loadsrrrr r!r r$r%r )rgbufspobjcannedr,newobjr-s rdeserialize_objectr7ns =D 88A;D \\$ F fn%%#f+ *AA Q %* <   #f+ "9A A Q %a FI  < &v! <rc^^^[[R"UU4SjU555n[TR 55n[[R"UUU4SjU555n[ [ U5[ U5US9n[R"[U5[5/n U R[R"U[55 U RU5 U RU5 U $)apack up a function, args, and kwargs to be sent over the wire Each element of args/kwargs will be canned for special treatment, but inspection will not go any deeper than that. Any object whose data is larger than `threshold` will not have their data copied (only numpy arrays and bytes/buffers support zero-copy) Message will be a list of bytes/buffers of the format: [ cf, pinfo, , ] With length at least two + len(args) + len(kwargs) c3>># UHn[UTT5v M g7fNr.).0argr)r*s r %pack_apply_message..s"d_cX[,S2BNSS_csc3D># UHn[TUTT5v M g7fr:r;)r<keyr)r*kwargss rr>r?s( W^PS VC[*:N K KW^s )nargs narg_bufskw_keys) r0r from_iterabler%keysr$rr'r(rr rr#) fargsrBr)r*arg_bufsrE kwarg_bufsinfomsgs ``` rpack_apply_messagerNs  d_cddHV[[]#G  W^  J c$i3x=' JD <<A 0 1CJJv||D/23JJxJJz Jrc[U5n[U5S:dS5eURS5n[[R "U5U5nURS5n[R "U5nUSUSXSSp/n [ US5H!n [Xq5upU RU 5 M# [U 5n U(aS5e0n USHn[X5upXU'M U(aS 5eXLU 4$) z`unpack f,args,kwargs from buffers packed by pack_apply_message() Returns: original f,args,kwargsrznot enough buffers!rNrDrCz#Shouldn't be any arg bufs left overrEz%Shouldn't be any kwarg bufs left over) r0rr r r'r1ranger7rtuple)r3r2copypfrHpinforLrJrK args_list_r=rIrBrAkwargs runpack_apply_messagerXs  :D t9>000> !B fll2"A HHQKE << D 3${"34d ;L;N6OjI 4= !*87 "  D>>>< FI.z=s BBB> F?rr:)NT)__doc__r'warnings itertoolsripyparallel.serialize.canningrrrrrr r ipyparallel.serialize.serializer ImportErroripykernel.pickleutiljupyter_client.sessionr r warnDeprecationWarningrr!r.r7rNrXrrrds0 @8 N%.  0,5Y#L@:CS\"J{     sA&&BB