ڻfi&SSKJr SSKJrJr SSKJr SSKrSSKrSSK r SSK r SSK r SSK Jr SSKJr SSKJrJr SSKJr SS KJr S /rSS KJr S S jrS!S jrS"SjrSrSrS#S$Sjjr \ "S5r!\!(d\""S5eS%Sjr#S%Sjr$S&Sjr%S'Sjr&S'Sjr'SS KJr S(Sjr(\"SS55r)SSS.S)Sjjr*g)*) annotations) dataclassasdict)PathN) get_engine)QUERY_FOLIOS_AGG) FOLIOS_DIR ensure_dirs)service_account)buildz%https://www.googleapis.com/auth/drive)MediaFileUploadc[U5nUR5(d<[[5R5RSnX!- R5n[ U5$)N)r is_absolute__file__resolveparentsstr)path_strpROOTs dC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\Proyectos\cabanna-api\app\dwh\etl_folios.py_resolve_sa_pathrsN XA ==??H~%%'//2 X    q6McU=(d SR5nURS5=(a URS5$)N{})strip startswithendswith)ss r_looks_like_jsonr#s. bA <<  0C0rc[U5nURS5n[U[5(a7SU;aUR SS5nUR S5(dUS- nXS'U$)ut Asegura que private_key tenga saltos de línea reales. Sirve tanto si viene con \n escapados como si viene normal. private_keyz\n )dictget isinstancerreplacer!)infopks r_normalize_private_keyr-!sd :D - B"c B;E4(B{{4  $JB ] KrcP[R"S5nU(d [S5eUR5R SS5n[ U5(aD[ R"U5n[U5n[RRU[S9$[U5n[R R#U5(d[SUS 35e[RR%U[S9$![ Ran[SU35UeSnAff=f) u ÚNICA función válida para local + producción. Prioridad: 1) Streamlit Cloud secrets: [gcp_service_account] (dict) 2) ENV GDRIVE_SA_JSON como JSON (texto) 3) ENV GDRIVE_SA_JSON como ruta a archivo .json (local) GDRIVE_SA_JSONz|Falta credencial. Define: - Streamlit Secrets: [gcp_service_account] o - ENV: GDRIVE_SA_JSON (JSON completo o ruta al .json)z r&uGDRIVE_SA_JSON parece JSON pero no es válido. Si lo pegaste en secrets como string, asegúrate de que el private_key use \n escapados. Recomendado: usa [gcp_service_account] en Streamlit secrets. Detalle: N)scopesz-No encuentro el JSON del Service Account en: um En local: define GDRIVE_SA_JSON como ruta válida. En Streamlit Cloud: usa [gcp_service_account] en Secrets.)osgetenvFileNotFoundErrorrr*r#jsonloadsJSONDecodeError RuntimeErrorr-r Credentialsfrom_service_account_infoSCOPESrpathexistsfrom_service_account_file)rawr+e json_paths r_load_sa_credentials_from_envrA0s% ))$ %C  D   ))+  fd +C ::c?D&d+**DDTRXDYY!%I 77>>) $ $;I;GH H   & & @ @SY @ ZZ)## 3     sC==D%D  D%c,[5n[SSUS9$)Ndrivev3) credentials)rAr )credss rget_drive_servicerG`s ) +E $E 22rc[R"U5nUb6[U5R5S:wa[U5R5$U$)Nr)r1r2rr)keydefaultvs r get_settingrLds< #A}Q2-1v||~ NrFOLDER_ID_FOLIOSz6Falta FOLDER_ID_FOLIOS en .env o variables de entorno.c<UR5RSS9$)N)day) normalizer*dts r month_startrTqs <<> ! !a ! ((rcbU[RRS5-R5$)NrO)pdoffsets MonthBeginrQrRs r next_monthrYts% &&q) ) 4 4 66rc## [U5n[R"U5nX!:a'[U5nUn[ X15nXE4v UnX!:aM&gg7fN)rTrV to_datetimerYmin)start_dtend_dtcurnxtinifins r month_rangesrdwsM h C ^^F #F ,o#h ,s A AAcUR5(dgSnURS5H6nUR5(dMXR5R- nM8 U$)Nr*)r<rglobis_filestatst_size)r;totalrs r_dir_size_bytesrlsM ;;== E ZZ_ 99;; VVX%% %E LrcX[R"[U55nUR$r[)shutil disk_usagerfree)r;usages r_disk_free_bytesrrs   c$i (E ::rc[5nSUSUS3nUR5RUSS9R5nUR S/5n[ USS9nU(a3UR5R US S US 9R5 gUR5RX/S .US 9R5 g)N'z' in parents and name='z' and trashed=falsez files(id))qfieldsfilesT) resumablerid)fileId media_body)namer)bodyr{)rGrwlistexecuter(r updatecreate) folder_idfilename local_pathserviceruresrwmedias rupload_or_replace_in_drivers!G I;-hZ7JKA --/  ;  7 ? ? AC GGGR E J$ 7E  8D>   ')  "{;   ')rc\rSrSr%S\S'S\S'S\S'S\S'S\S'S\S 'S\S 'S \S 'S \S'S \S'S\S'S\S'S \S'Srg)EtlFoliosResultrstatusstartendint files_written rows_written months_total months_emptyz list[str] empty_months str | Nonelast_nonempty_end last_filefolios_dir_bytesdisk_free_byteswarningsN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__rrrrrsM K J H!!rrrO)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 [1[ 5n[3[ 5nUS:aU RS5 US:aU RS5 [5SUUUUU U U SSU bU R75OSUb [9U5OSUUU S9 nUS:Xa"SUlUR<RS5 [?U5$!,(df  GN=f)u Construye parquets mensuales folios_YYYY_MM.parquet. - NO guarda archivos vacíos. - Opcional: se detiene tras N meses consecutivos vacíos. - Regresa un resumen (para que /etl/folios lo reporte). rNrOz%Y-%mfolios_z%Y_%mz.parquet)paramsFechacoerce)errorszSe detuvo por u6 meses consecutivos sin datos. Último mes procesado: z (rango u→z).F)deletesuffix)index)rrri/hYziCarpeta folios supera ~1.5GB; considera mover parquets a almacenamiento persistente (S3/GCS/Render Disk).iʚ;u`Espacio libre en disco bajo (<~1GB). Podrías quedarte sin espacio al seguir generando parquets.oki) rrrrrrrrrrrrrno_datauZNo se escribió ningún parquet con datos. Revisa QUERY_FOLIOS_AGG y/o el rango de fechas.) r rrVr\rdstrftimer connectread_sqlremptycolumnslenappenddatetempfileNamedTemporaryFile to_parquetr|closerrMr1unlinkrlrrr isoformatrrrr)rrrrenginer^r_rrrrrrrrconsecutive_emptyrbrcymoutconndftmprrrs rbuild_folios_parquetrsM \F~~e$H ^^C FMLLL LH-1!I 2S \\' "WS\\'%:$;8DD ^^ -tS#JGB xxGrzz1..GXFBwK :R#44 A L    #  " )->-[$%6$78..0T#((*S TVX ))zJ chhe , "&XXxx #((  B  e3j'z2&z2O-'D E&z{  #!!!!#$';L;X+557^b$-$9#i.t)' C"  xy #;_ s 'K K' )rrreturnr)r"rrbool)r+r'rr'r[)rIrrJrrr)rS pd.Timestamprr)r^rr_r)r;rrr)rrrrrr) rrrrrrrrrr')+ __future__r dataclassesrrpathlibrr1rnpandasrVr4rapp.dbr app.queriesr app.dwh.pathsr r google.oauth2r googleapiclient.discoveryr r:googleapiclient.httpr rr#r-rArGrLrMr7rTrYrdrlrrrrrrrrrs")  (1)+ 1 20 1 .[`312 O PP)7 1.     (&' t t t # t  t  tr