Ensure merge queue data is backfilled and today is fresh.
()
| 619 | |
| 620 | |
| 621 | def ensure_merge_queue_data(): |
| 622 | """Ensure merge queue data is backfilled and today is fresh.""" |
| 623 | global _mq_last_refresh |
| 624 | now = time.time() |
| 625 | if now - _mq_last_refresh < _MQ_REFRESH_TTL: |
| 626 | return |
| 627 | if not _mq_backfill_lock.acquire(blocking=False): |
| 628 | return |
| 629 | try: |
| 630 | _backfill_merge_queue() |
| 631 | refresh_merge_queue_today() |
| 632 | _mq_last_refresh = now |
| 633 | finally: |
| 634 | _mq_backfill_lock.release() |
| 635 | |
| 636 | |
| 637 | def get_merge_queue_stats(date_from: str, date_to: str) -> dict: |
no test coverage detected