+ qj>Rt^RIHtRtRtRtRtRRltRRltR#) u)Quando é que uma entidade foi reclamada da fila de histórico. A fila de conteúdo já recupera sozinha o que ficou pendurado: o `take_content` reclama também os actos em `running` há mais de 15 minutos, porque nenhum demora isso e quem lá estiver morreu. A fila de entidades nunca precisou disso — só o CT a consumia, em processo único, e um restart do contentor levava tudo consigo. Passa a ser consumida também pelo trabalhador remoto, noutra máquina e noutra linha. Um worker que morra a meio deixaria entidades em `running` **para sempre**, invisíveis à fila e sem nada a acusar; com 507 mil na fila, ninguém daria por elas. É o mesmo mecanismo, pela mesma razão. Fica NULL para quem nunca foi reclamado, e a condição do `take_from_queue` trata esse caso como "não está pendurado". )op00330032NcV^8dQhRR/#returnN)formats"+alembic/versions/0033_entity_fetch_claim.py __annotate__r s   c^\P!R4\P!R4R#)zCALTER TABLE registry_entity_fetch ADD COLUMN claimed_at TIMESTAMPTZzx CREATE INDEX ix_rfetch_running ON registry_entity_fetch (claimed_at) WHERE status = 'running' Nrexecuter r r upgraders"JJTUJJ r cV^8dQhRR/#rr )r s"r r r $sKK4Kr c^\P!R4\P!R4R#)z&DROP INDEX IF EXISTS ix_rfetch_runningz8ALTER TABLE registry_entity_fetch DROP COLUMN claimed_atNrr r r downgrader$sJJ78JJIJr ) __doc__alembicrrevision down_revision branch_labels depends_onrrr r r rs.     Kr