+ WjRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI H t H t ^RI H t ^RIHtHtHtHt^RIHt^RIHt^RIHtHt^R IHt^R IHt^R IHtHtH t H!t!H"t"H#t#H$t$H%t%H&t&^R I'H(t(H)t)R t*Rt+^t,Rt-Rt.^t/Rt0Rt1Rt2Rt3Rt4]!^R7t5R+t6Rt7Rt8Rt9R,t:R]8RR3t;Rt]P~!]@4tARR ltBR!R"ltCR#R$ltDR%R&ltER'R(ltF!R)R*4tGR#).z?Durable aggregation and local export for Hermes shared metrics.) annotationsN)CallableIterator)contextmanager)datetime timedeltatimezoneUTC)Path)Any)add_column_if_missing write_txn)get_hermes_home)atomic_json_write) CLIENT_ACTIVE_METRICCOUNTER_METRICSFEATURE_ADOPTION_METRICINSTALL_SNAPSHOT_METRICMILESTONE_METRICMODEL_ROUTE_METRIC SUM_METRICSclient_resource_is_validcounter_dimensions_are_valid)conform_counter_dimensions!counter_dimensions_shape_is_knownzhermes.shared_metrics.v42iiclient_active_recorded_atinstall_snapshot_recorded_atz milestone:zfeature:z daily_once:)hoursz CREATE TABLE IF NOT EXISTS telemetry_state ( key TEXT PRIMARY KEY, value TEXT NOT NULL ) a CREATE TABLE IF NOT EXISTS counter_aggregates ( period_start TEXT NOT NULL, metric_name TEXT NOT NULL, hermes_version TEXT NOT NULL, os_family TEXT NOT NULL, architecture TEXT NOT NULL, install_method TEXT NOT NULL, dimensions_json TEXT NOT NULL, value INTEGER NOT NULL, packaged_value INTEGER NOT NULL DEFAULT 0, PRIMARY KEY ( period_start, metric_name, hermes_version, os_family, architecture, install_method, dimensions_json ) ) aM CREATE TABLE IF NOT EXISTS package_outbox ( package_id TEXT PRIMARY KEY, period_start TEXT NOT NULL, period_end TEXT NOT NULL, payload_json TEXT NOT NULL, created_at TEXT NOT NULL, exported_at TEXT ) z>ALTER TABLE counter_aggregates RENAME TO counter_aggregates_v1a INSERT INTO counter_aggregates( period_start, metric_name, hermes_version, os_family, architecture, install_method, dimensions_json, value, packaged_value ) SELECT period_start, metric_name, hermes_version, 'unknown', 'unknown', 'unknown', dimensions_json, value, packaged_value FROM counter_aggregates_v1 z DROP TABLE counter_aggregates_v1ag SELECT COUNT(*) AS period_count FROM ( SELECT period_start, hermes_version, os_family, architecture, install_method FROM counter_aggregates WHERE value > packaged_value GROUP BY period_start, hermes_version, os_family, architecture, install_method ) a INSERT INTO counter_aggregates( period_start, metric_name, hermes_version, os_family, architecture, install_method, dimensions_json, value, packaged_value ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, 0) ON CONFLICT( period_start, metric_name, hermes_version, os_family, architecture, install_method, dimensions_json ) DO UPDATE SET value = value + excluded.value cV^8dQhRR/#)returnr)formats"[C:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_cli\observability\shared_metrics.py __annotate__r%s(c6\P!\4#N)rnowr r"r&r$_utc_nowr*s << r&c V^8dQhRRRR/#)r valuerr!strr")r#s"r$r%r%sDDhD3Dr&chVP\4P4PRR4#)z+00:00Z) astimezoner isoformatreplacer,s&r$ _isoformatr4s)   C * * , 4 4Xs CCr&c V^8dQhRRRR/#)r r,r r!r-r")r#s"r$r%r%sDDDDr&c4\P!VRRR7#)T) sort_keys separators,:)jsondumpsr3s&r$ _compact_jsonr>s ::et CCr&c V^8dQhRRRR/#)r row sqlite3.Rowr!dict[str, str]r")r#s"r$r%r%sAA{A~Ar&cD\Uu/uF qW,bK up#uupir()_RESOURCE_COLUMNS)r@columns& r$ _row_resourcerFs!.? @.?FCK .? @@ @sc$V^8dQhRRRRRR/#)r pathr modeintr!Noner")r#s"r$r%r%s!  $ c d r&cVR8XdVPRRVR7MVPVRR7VPV4R# \dR#i;i)T)parentsexist_okrI)rIrON)mkdirtouchchmodOSError)rHrIs&&r$_ensure_privaterTsN u} 4$T : t ,  4    sA AAcP]tRt^tRtRPRRlltRRltRRltR R ltR R lt R Rlt RQRRllt RRlt RRlt RRltRRltRRltRRltRRltRR ltR!R"lt]R#R$l4t]RQR%R&ll4tR'R(ltR)R*lt]3R+R,lltR-R.ltR/R0ltR1R2lt]R3] /R4R5ll4t!]R3] /R6R7ll4t"R8R9lt#R:R;lt$]R<R=l4t%R>R?lt&R@RAlt'RBRClt(]RDREl4t)]*RFRGl4t+]RHRIl4t,RJRKlt-RLR/RMRNllt.ROt/R#)RSharedMetricsStorezAPersist allowlisted counters and export immutable delta packages.Nc$V^8dQhRRRRRR/#)r database_pathz Path | Noneoutbox_directoryr!rKr")r#s"r$r%SharedMetricsStore.__annotate__s$ $ $( $CN $  $r&c \4R, R, pT;'g VR, VnT;'g VR, Vn\VPPR4\VPR4\VPR4VP 4.Vn\P!4Vn RVn R#) telemetryshared_metricszmetrics.sqlite3outboxrMFN) rrXrYrTparent_ensure_schema _deferred threadingLock_deferred_lock_drain_at_exit)selfrXrYroots&&& r$__init__SharedMetricsStore.__init__s ;.1AA*FFd5F.F 0 C CD8O**1159--u5**E2 EG'nn.#r&c$V^8dQhRRRRRR/#)r dimensionsrBresourcer!rKr")r#s"r$r%rZs'FFNFnFY]Fr&c 2VP\W4R#)zBIncrement the terminal model-call counter for the current UTC day.N)record_counterrrgrlrms&&&r$record_model_call$SharedMetricsStore.record_model_calls . Er&c V^8dQhRRRR/#)r rmrBr!boolr")r#s"r$r%rZs  ^  r&c :VP\\/V4#)z?Record this install at most once in any rolling 24-hour window.)_record_once_per_interval_ACTIVE_INSTALL_STATE_KEYr)rgrms&&r$record_client_active'SharedMetricsStore.record_client_actives-- %';R  r&c$V^8dQhRRRRRR/#)r rlrBrmr!rtr")r#s"r$r%rZs"  . N _c r&c 8VP\\W4#)zMRecord the configuration snapshot at most once in any rolling 24-hour window.)rv_INSTALL_SNAPSHOT_STATE_KEYrrps&&&r$record_install_snapshot*SharedMetricsStore.record_install_snapshots-- ')@*  r&cV^8dQhRR/#)r r!rtr")r#s"r$r%rZsTTdTr&c RVP4;_uu_4pVPR\34P4pRRR4XeVP VR,4MRp\ 4pVRJ;'gW48;'gWC\ ,8# +'giL_;i)zLCheap read so the producer skips collecting a snapshot the latch would drop./SELECT value FROM telemetry_state WHERE key = ?Nr,) _connectionexecuter|fetchone_parse_state_timestampr*_ACTIVE_INSTALL_INTERVAL)rg connectionr@lastr)s& r$install_snapshot_due'SharedMetricsStore.install_snapshot_dues     :$$AD_Cahj  =@Ot**3w<8QUjt|SStzSSS;S4S-SS  s &B B& c ,V^8dQhRRRRRRRRRR/# r state_keyr- metric_namerlrBrmr!rtr")r#s"r$r%rZs6+.3SharedMetricsStore.record_counter..s0S0S  Z<1 r&N) r isinstancertrJr ValueErrorr*rr1_write_or_defer)rgrrlrmrrsfffff@r$ro!SharedMetricsStore.record_counters {JA fd # #:fc+B+Bfqj aKK{:Ek]ST Tz(224     r&c$V^8dQhRRRRRR/#)r rr-update[Callable[[dict[str, Any] | None], tuple[dict[str, Any], list[tuple[str, dict, dict, str]]]]r!rKr")r#s"r$r%rZs+ j j jk j  jr&c :aaaSPVVV3Rl4R#)aRead-modify-write one JSON rollup state and record the ``(metric, dimensions, resource, period_start)`` rows ``update`` closes, in one write transaction: every process of the profile serializes here, so a closed period is emitted exactly once. Rows the contract rejects are dropped (never retried) so one bad row cannot wedge the rollup. A busy store defers the update to the next write (it then runs with that write's clock).c*<SPVSS4#r()_update_rollup_state)rrgrrs&r$r8SharedMetricsStore.update_rollup_state..s0I0I*V_ag0hr&N)r)rgrrsfffr$update_rollup_state&SharedMetricsStore.update_rollup_states hir&c(V^8dQhRRRRRRRR/#) r rsqlite3.Connectionrr-rrr!rKr")r#s"r$r%rZ s.  , 9< k   r&c TVPRV34P4pVe\P!VR,4MRpT!\ V\4'dTMR4wrgVUu.uFAp\V^,V^,4'gK%\V^,4'gK?VNKC p pV 'dVPV4V FwrrVPWWV 4K VPRV\V434R# \\ 3dRpLi;iuupi)rNr,r) rrr<loads TypeErrorrrdictrrrrr>)rgrrrr@state new_staterowsrvalidrrlrmrs&&&& r$r'SharedMetricsStore._update_rollup_state s  = | (*  03DJJs7|,TE!*UD*A*AtL  !+AaD!A$7  YW %%)@(A)&MO_akvvr&cV^8dQhRR/#rr")r#s"r$r%rZCs44>4r&c ,VP\4#r()r_FEATURE_STATE_PREFIXrs&r$recorded_features$SharedMetricsStore.recorded_featuresCs}}233r&c(V^8dQhRRRRRRRR/#)r featurer- days_bucketrmrBr!rtr")r#s"r$r%rZFs0zzszzP^zcgzr&c LRVRV/pVP\ V 2\WC4#)zWRecord a feature's first use at most once per install, ever (same latch as milestones).days_since_install_bucketr)rrr)rgrrrmrls&&&& r$record_feature_adoption*SharedMetricsStore.record_feature_adoptionFs21; 7S %%)>(?y&IKbdnyyr&c(V^8dQhRRRRRRRR/#)r rr-rlrBrmr!rtr")r#s"r$r%rZKs*sbpuyr&c  $VPWV4\4pVP4P4p\ V R2\ VP 4UUu/uFwrgVR8wgKWgbK upp4,pVP4;_uu_4p V PRW34Pp V 'g RRR4R#VPV 4VPWW#V4RRR4R#uuppi +'giR#;i)zCount at most once per UTC day per dimension set, whatever the surface (``surface`` is attribution of the first one that day). One state row per dimension set, overwritten daily.r;surfacezINSERT INTO telemetry_state(key, value) VALUES (?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value WHERE telemetry_state.value != excluded.valueNFT) rr*rr1_DAILY_ONCE_STATE_PREFIXr>itemsrrrowcountrr) rgrrlrmr)todaykvkeyrchangeds &&&& r$record_counter_once_per_day.SharedMetricsStore.record_counter_once_per_dayKs {Aj $$&)*;-q9M(..0 C0daANTQT0 C=EE [[]]j ((\ h  ]   Z (  / / _d e D ]s C8 -C8 'C> $C>> D c V^8dQhRRRR/#)r prefixr-r!rr")r#s"r$r%rZ`sCCsC~Cr&c aVP4;_uu_4pVPRS R234P4pRRR4\V3RlX44# +'giL%;i)z0SELECT key FROM telemetry_state WHERE key LIKE ?%Nc3L<"TFqR,\S4RxK R#5i)rN)len).0r@rs& r$ .SharedMetricsStore._latched..esBTcUCKL1Ts!$)rrfetchall frozenset)rgrrrs&f r$rSharedMetricsStore._latched`s\     :%%Bxq\Ohj  BTBBB  s %A A, c ,V^8dQhRRRRRRRRRR/#rr")r#s"r$r%rZgs4+..s,^L]&Xf-=-=L]N)r_INCREMENT_COUNTER_SQLrDr>)rrrlrmrrs&&&f&&r$r1SharedMetricsStore._record_counter_in_transactionsA  " ,^L],^ j) +1  r&cV^8dQhRR/#r r!z list[Path]r")r#s"r$r%rZs((:(r&c fVP4;_uu_4pVP\4P4pRRR4\ Xe\ VR,4M^4F&pVP 4eKVP4# VP4# +'giLk;i)zLCommit every pending delta package (one per period), then export the outbox.N period_count)rr_PENDING_PERIOD_COUNT_SQLrrangerJ_create_package_export_and_prune)rgrr@_s& r$create_and_export_package,SharedMetricsStore.create_and_export_packages     :$$%>?HHJC 3?s3~./JA##%-%%''K%%''  s $B  B0 c V^8dQhRRRR/#)r writez$Callable[[sqlite3.Connection], None]r!rKr")r#s"r$r%rZs%Idr&c VP;_uu_4.VPOVN.uq nRRR4VP4;_uu_4pXF pV!V4K RRR4R# +'giLE;i +'giR#;i \PdpR\ T49;'gR\ T49pTP;_uu_4.T'dXMXRROTPO\ )RTnTP'*RuqpnRRR4M +'giM;iX'd!\P!TP4T'ghRp?R#Rp?ii;i)zRun ``write`` (after any deferred ones) in one write transaction. A store another writer holds past the short busy timeout keeps them in memory for the next write or process exit instead of losing them or stalling the caller.NlockedbusyT) rerbrsqlite3OperationalErrorr-_DEFERRED_WRITES_MAXrfatexitregisterdrain_deferred)rgr pendingritemexcr rs&& r$r"SharedMetricsStore._write_or_defers! &>&>&> #G^! *#D$$! '' s3x'==6SX+=D$$$!XtG"!X!XZnYnYo!p484G4G0G--%$$$ 3 34 seA*BA= B* A: = B BBE9&8E4AD*! E4* D: 5E4'E4-E44E9c V^8dQhRRRR/#)r busy_timeout_msrJr!rKr")r#s"r$r%rZs n nc nPT nr&c VP;_uu_4VP.uq nRRR4X'gR#VPVR7;_uu_4pVF pV!V4K RRR4R# +'giLQ;i +'giR#;i \d&\P R\ T4RR7R#i;i)zYWrite the deferred writes (process exit / export waits longer than the user's path does).Nrz2Unable to write %d deferred shared-metrics updatesTexc_info)rerbr Exceptionloggerwarningr)rgrrrrs&& r$r!SharedMetricsStore.drain_deferreds  &*nnb #G^!  n_==#D$$>= ! >== n NNOQTU\Q]hlN m ns:A2BB(B2 B  B BB,C C cV^8dQhRR/#rr")r#s"r$r%rZs((*(r&c lVP\4VP4VP4#)zCCreate pending packages at most once per UTC day, then export them.)r_BUSY_TIMEOUT_MS_create_pending_packages_if_duerrs&r$ create_and_export_package_if_due3SharedMetricsStore.create_and_export_package_if_dues, ,- ,,.%%''r&cV^8dQhRR/#rr")r#s"r$r%rZs:r&c VP4pVP4V# \d\P RRR7T#i;i)z.Unable to prune expired shared-metrics historyTr)_export_pending_packages_prune_expired_historyrr r!)rgexporteds& r$r$SharedMetricsStore._export_and_prunesS002 \  ' ' ) \ NNKVZN [ \s$"A  A cV^8dQhRR/#)r r!list[dict[str, Any]]r")r#s"r$r%rZs  "6 r&c nVP4;_uu_4pVPR4P4pRRR4XUu.uFQpRVR,RVR,R\V4R\P !VR,4RVR,R VR ,/NKS up# +'giLn;iuupi) zBReturn cumulative counters for focused tests and local inspection.ap SELECT period_start, metric_name, hermes_version, os_family, architecture, install_method, dimensions_json, value, packaged_value FROM counter_aggregates ORDER BY period_start, hermes_version, os_family, architecture, install_method, metric_name, dimensions_json Nrrrmrldimensions_jsonr,packaged_value)rrrrFr<r)rgrrr@s& r$counter_snapshot#SharedMetricsStore.counter_snapshots     :%%hj     N 3]C DVM#. djjM^I_>`W'7=M9N       s BAB2 B/ rc V^8dQhRRRR/#r rrJr!zIterator[sqlite3.Connection]r")r#s"r$r%rZs  "%  % r&c# R"\P!VPVR, R7p\PVnVP RV 24V;_uu_4VxRRR4VP 4R# +'giL";i TP 4i;i5i)i)timeoutzPRAGMA busy_timeout=N)rconnectrXRow row_factoryrclosergrrs&$ r$rSharedMetricsStore._connections__T%7%7SWAWX  %,[[J "   !5o5FG H          s4*B'3B A?%B-B'? B BB$$B'c V^8dQhRRRR/#r7r")r#s"r$r%rZs!!!D`!r&c # "VPVR7;_uu_4p\V4;_uu_4VxRRR4RRR4R# +'giL;i +'giR#;i5i)z*A connection inside one write transaction.rN)rr r>s&$ r$rSharedMetricsStore._writesM  o  > >*:&&  '? >&&? > >s1A/AA A A/ A A A, & A/cV^8dQhRR/#r r!rKr")r#s"r$r%rZs###r&c  VP\R7;_uu_4pVP\4VPR4P 4pVe\ VR,4MRpVR8Xd%\ FpVPV4K \pVeV\8wd\RV 24hVP\4VP\4VPR4Uu0uFp\ VR,4kK pp\FwrxWv9gK \VRWw R V 24K! \FpVPV4K VPR \34RRR4R#uupi +'giR#;i) rz>SELECT value FROM telemetry_state WHERE key = 'schema_version'Nr,1z1Unsupported shared-metrics store schema version: z!PRAGMA table_info(package_outbox)namepackage_outbox zzINSERT INTO telemetry_state(key, value) VALUES ('schema_version', ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value)r_SCHEMA_BUSY_TIMEOUT_MSr_CREATE_TELEMETRY_STATE_SQLrr-_MIGRATE_V1_SQL_STORE_SCHEMA_VERSION RuntimeError_CREATE_COUNTER_AGGREGATES_SQL_CREATE_PACKAGE_OUTBOX_SQL _SEND_COLUMNSr _CREATE_CONSENT_TABLES_SQL) rgr schema_rowschema_version statementr@existingrE declarations & r$ra!SharedMetricsStore._ensure_schemas~ [[)@[ A AZ   : ;#++Phj :D9OSG!45UYN$!0I&&y1"1!6)n@U.U"GGWX   = >   9 :&--.QRRCCK R (5#))*6FRZZ[\g[hPij(58 ""9-8   I&( ;B A()B A As%CE;1E6 E;!A E;6E;; F c V^8dQhRRRR/#)r rrr!r-r")r#s"r$r%rZs ! !&8 !S !r&c *RpVPV4P4pVfOVPR\\P!4434VPV4P4pVf \ R4h\VR,4#)z:SELECT value FROM telemetry_state WHERE key = 'install_id'zJINSERT OR IGNORE INTO telemetry_state(key, value) VALUES ('install_id', ?)z4Unable to create the shared-metrics install identityr,)rrr-uuiduuid4rN)rgrqueryr@s&& r$rSharedMetricsStore._install_idsL  '002 ;   \TZZ\"$ $$U+446C ;UV V3w<  r&c V^8dQhRRRR/#)r r,r r!datetime | Noner")r#s"r$r%rZ*sIIcIoIr&c \P!\V44pTP fR#TP \4# \\3dR#i;ir()r fromisoformatr-rrtzinfor0r )r,parseds& r$r)SharedMetricsStore._parse_state_timestamp)sU ++CJ7F}},tH&2C2CC2HH:&  sAAAcV^8dQhRR/#rDr")r#s"r$r%rZ1s   r&c 0\4pVP4;_uu_4pVPRVP4P 434P 4pVfVP W!4eKRRR4R# +'giR#;i)zISELECT 1 FROM package_outbox WHERE substr(created_at, 1, 10) >= ? LIMIT 1N)r*rrrr1r_create_package_in_transaction)rgr)rpackage_created_todays& r$r&2SharedMetricsStore._create_pending_packages_if_due1stj [[]]j%/$6$6[%%')%hj "%,99*JV]]]s AB B cV^8dQhRR/#)r r!dict[str, Any] | Noner")r#s"r$r%rZ>sOO!6Or&c VP4;_uu_4pVPV\44uuRRR4# +'giR#;ir()rrhr*)rgrs& r$r"SharedMetricsStore._create_package>s- [[]]j66z8:N]]]s > A c$V^8dQhRRRRRR/#)r rrr)rr!rlr")r#s"r$r%rZBs$<<,<3;< <r&c a VPR4P4pVeVR,'gR#VR,p\V4o \;QJd.V 3Rl\4FNK 5M!V 3Rl\44pVPRV.VO54P 4p\ P!\V44P\R7p\S 4'g \R4hVPV4pV'g$VPWWE4VPW4#R\ R\\"P$!44R VP'V4R\)V4R \)V\+^R 7,4R \)V4R S RV/p VPRV R,V R,V R ,\-V 4V R ,34VPRV R ,34VPWWE4V #)a* SELECT period_start, hermes_version, os_family, architecture, install_method FROM counter_aggregates WHERE value > packaged_value ORDER BY period_start, hermes_version, os_family, architecture, install_method LIMIT 1 Nrc36<"TFpSV,xK R#5ir(r"rs& r$rDSharedMetricsStore._create_package_in_transaction..RsQ?PV 0 0?PraS SELECT metric_name, dimensions_json, value, packaged_value FROM counter_aggregates WHERE period_start = ? AND hermes_version = ? AND os_family = ? AND architecture = ? AND install_method = ? AND value > packaged_value ORDER BY metric_name, dimensions_json )rcrrT package_id install_id period_enddays generated_atrmmetricszsINSERT INTO package_outbox( package_id, period_start, period_end, payload_json, created_at ) VALUES (?, ?, ?, ?, ?)z|INSERT INTO consent_marks(name, stamp) VALUES ('data', ?) ON CONFLICT(name) DO UPDATE SET stamp = MAX(stamp, excluded.stamp))rrrFtuplerDrrrbr-r2r rr_package_metrics_mark_packagedrh_PACKAGE_SCHEMA_VERSIONr[r\rr4rr>) rgrr) period_row period_valueresource_valuesrrrypayloadrms &&& @r$rh1SharedMetricsStore._create_package_in_transactionBs ''   (*   Z%?%?!.1  ,%Q?PQ%%Q?PQQ!!   ,O ,  (*  --c,.?@HHPSHT '11IJ J''-    , P66zG G 5 #djjl+ $**:6 J|4 *\I14E%EF JsO  w    3 %w~'> @Ug&(?    R \ " $ JlLr&c ,V^8dQhRRRRRRRRR R /#) r rrrlist[sqlite3.Row]rr-rrzr!rKr")r#s"r$r%rZs4  & .? OR ej   r&c dVF)pVPRW$R,.VOVR,N54K+ R#)a6 UPDATE counter_aggregates SET packaged_value = value WHERE period_start = ? AND metric_name = ? AND hermes_version = ? AND os_family = ? AND architecture = ? AND install_method = ? AND dimensions_json = ? rr2N)r)rrrrr@s&&&& r$r|!SharedMetricsStore._mark_packageds>C    =1\O\SIZE[\ r&c V^8dQhRRRR/#)r rrr!r0r")r#s"r$r%rZs % %$5 %:N %r&c /pVFcpVPV4pVfKVR,\VR,43pWR9d%W%,R;;,VR,, uu&K_WBV&Ke \VP44#)zWPackage rows, merging rows a re-bucket folded onto the same dimensions into one metric.rGrlr,)_package_metricr>listvalues)clsrmergedr@metricrs&& r$r{#SharedMetricsStore._package_metricssx9;C((-F~&>= 1E#FGC} G$w7$$s FMMO$$r&c V^8dQhRRRR/#)r r@rAr!rlr")r#s"r$r%rZs  [ -B r&c  \VR,4p\P!VR,4p\V\4'd\ W4'g\ RV 24h\W4'gJ\W4pVf\PRV4R#\PRV\V44TpRVRRR VR VR ,VR ,, /#) rr2rNzGShared-metric %s row holds a retired value with no bucket; not packagedzlShared-metric %s row drifted out of the contract since it was recorded; packaged with bucketed dimensions %srGtypecounterrlr,r3) r-r<rrrrrrrr infor>)r@rrl conformeds& r$r"SharedMetricsStore._package_metrics#m,- ZZ$5 67 *d++3TU`3m3mI+WX X+KDD2;KI  egrs KK78C]S\E] #J KL* S\C(8$99  r&cV^8dQhRR/#rr")r#s"r$r%rZs*r&c  >VP4;_uu_4pVPR4P4pRRR4.pXFp\VR,4pVPV R2, p\ V\ P!VR,4RR RRR7VP4;_uu_4pVPR\\44V34RRR4VPV4K V# +'giL;i +'giL:;i) zmSELECT package_id, payload_json FROM package_outbox WHERE exported_at IS NULL ORDER BY created_at, package_idNrs.json payload_jsonTr_)indentr8r7rIzVUPDATE package_outbox SET exported_at = ? WHERE package_id = ? AND exported_at IS NULLr9) rrrr-rYrr<rr4r*append)rgrrr-r@rsrHs& r$r++SharedMetricsStore._export_pending_packagess     :%%Mhj  "CS./J((j\+??D djj^!45dzU !!##z""D +Z8$ OOD !+ $#s C94&D 9 D D r)c V^8dQhRRRR/#)r r)r`r!rKr")r#s"r$r%rZs//_//r&c :T;'g \4\\R7, p\V4pVP 4;_uu_4pVP RV34P 4pRRR4.pXFMp\VR,4pVPV R2, PRR7VPV4KO VP4;_uu_4pVP R 4VFpVP R W34K VP R VP4P!434RRR4R# +'giL;i \d\PRTRR 7EK i;i +'giR#;i) zARemove exported local history after the bounded retention window.rvzxSELECT package_id FROM package_outbox WHERE exported_at IS NOT NULL AND exported_at < ? ORDER BY exported_at, package_idNrsrT) missing_okz1Unable to prune expired shared-metrics package %srzUPDATE package_outbox SET payload_json = '' WHERE exported_at IS NOT NULL AND send_state IN ('sent', 'rejected') AND payload_json != ''z_DELETE FROM package_outbox WHERE package_id = ? AND exported_at IS NOT NULL AND exported_at < ?a DELETE FROM counter_aggregates WHERE period_start < ? AND value = packaged_value AND NOT EXISTS ( SELECT 1 FROM package_outbox WHERE exported_at IS NULL AND substr(package_outbox.period_start, 1, 10) = counter_aggregates.period_start ) )r*r_LOCAL_HISTORY_RETENTION_DAYSr4rrrr-rYunlinkrrSr r!rrr1) rgr)cutoffcutoff_timestamprrremovable_package_idsr@rss &$ r$r,)SharedMetricsStore._prune_expired_historys|##y6S'TT%f-     :%%4"#  hj  ,.CS./J &&JrFrTrVr"r&r$rs-E"  .%77C,#   `5 "7<&"($2.U "" "E" '  $   8 $DDA D D r&