fi) SSKJr SSKJrJr SSKJr SSKrSSKr SSK r SSK J r SSK Jr SSKJrJr SSKJrJr \"S 5r\(d\"S 5eSS jrSS jrSS jr\"SS55rSSS.SSjjrg)) annotations) dataclassasdict)PathN) get_engine)QUERY_LINEAS_SUCURSAL) LINEAS_DIR ensure_dirs)upload_or_replace_in_drive get_settingFOLDER_ID_LINEASz6Falta FOLDER_ID_LINEAS en .env o variables de entorno.c<UR5RSS9$)N)day) normalizereplacedts dC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\Proyectos\cabanna-api\app\dwh\etl_lineas.py month_startrs <<> ! !a ! ((cbU[RRS5-R5$)Nr)pdoffsets MonthBeginrrs r next_monthrs% &&q) ) 4 4 66rc## [U5n[R"U5nX!:a'[U5nUn[ X15nXE4v UnX!:aM&gg7f)N)rr to_datetimermin)start_dtend_dtcurnxtinifins r month_rangesr&sM h C ^^F #F ,o#h ,s A AAc\rSrSr%S\S'S\S'S\S'S\S'S\S'S\S 'S\S 'S \S 'S \S'S \S'S \S'Srg)EtlLineasResult*strstatusstartendint files_written rows_written months_total months_emptyz list[str] empty_monthsz str | Nonelast_nonempty_end last_filewarningsN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__r7rrr(r(*sA K J H!!rr(r)stop_on_consecutive_emptymin_rows_to_writec[5 [5n[R"U5n[R"U5nSnSnSn Sn /n /n Sn SnSn[ XV5GHunnU S- n UR S5n[ SUR S5S3- nUR5n[R"[UUU4S9nSSS5 WR(d+S UR;a[R"US S S 9US 'Ub[U5U:afU S- n U RU5 US- nU(aAX:a<U RS US USUR5SUR5S3 5 OGM"Sn[R "SSS9nUR#UR$SS9 UR'5 [)[*UR$UR$S9 [,R."UR$5 US- nU[U5- nUn UnGM [3SUUUUU U U SSU bU R55OSUb [7U5OSU S9 nUS:Xa"SUlUR:RS5 [=U5$!,(df  GN=f![0a Nf=f![,R."UR$5 f![0a ff=f=f)u Construye parquets mensuales lineas_YYYY_MM.parquet y los sube a Drive. - NO sube archivos vacíos. - Se puede detener tras N meses consecutivos vacíos. - Regresa un resumen para logging / endpoints. rNrz%Y-%mlineas_z%Y_%mz.parquet)paramsFechacoerce)errorszSe detuvo por u6 meses consecutivos sin datos. Último mes procesado: z (rango u→z).F)deletesuffix)index) folder_idfilename local_pathoki) r+r,r-r/r0r1r2r3r4r5r6no_datauUNo se escribió ningún parquet con datos. Revisa QUERY_LINEAS_SUCURSAL y/o el rango.)r rrrr&strftimer connectread_sqlremptycolumnslenappenddatetempfileNamedTemporaryFile to_parquetnamecloser r osunlink Exceptionr( isoformatr*r+r6r)r,r-r?r@enginer r!r/r0r1r2r3r6r4r5consecutive_emptyr$r%ymoutconndftmpress rbuild_lineas_parquetrh9sM \F~~e$H ^^C FMLLL LH-1!I 2S \\' "WS\\'%:$;8DD ^^ 2D#sLBxxGrzz1..GXFBwK :R#44 A L    #  " (->-[$%6$78..0T#((*S TVX ))zJ  MM#((%M 0 IIK &*88   #((#  B  c3f  #!!!!#$';L;X+557^b$-$9#i.t C  st #;A L    #((#  sO'J A J.& J J  J+*J+.K!0 KK! K K!K K!)r pd.Timestampreturnri)r rir!ri) r,r*r-r*r?r.r@r.rjdict) __future__r dataclassesrrpathlibrr\pandasrrWapp.dbr app.queriesr app.dwh.pathsr r app.dwh.etl_foliosr r r RuntimeErrorrrr&r(rhr7rrrus") -1G12 O PP)7     $&' e e e # e  e  er