diff --git a/backend/btrixcloud/migrations/migration_0006_precompute_crawl_stats.py b/backend/btrixcloud/migrations/migration_0006_precompute_crawl_stats.py index 83f0961d4e..5003a88586 100644 --- a/backend/btrixcloud/migrations/migration_0006_precompute_crawl_stats.py +++ b/backend/btrixcloud/migrations/migration_0006_precompute_crawl_stats.py @@ -23,9 +23,14 @@ async def migrate_up(self): crawl_configs = self.mdb["crawl_configs"] crawls = self.mdb["crawls"] - configs = [res async for res in crawl_configs.find({})] + configs = [res async for res in crawl_configs.find({"inactive": {"$ne": True}})] if not configs: return for config in configs: - await update_config_crawl_stats(crawl_configs, crawls, config["_id"]) + config_id = config["_id"] + try: + await update_config_crawl_stats(crawl_configs, crawls, config_id) + # pylint: disable=broad-exception-caught + except Exception as err: + print(f"Unable to update workflow {config_id}: {err}", flush=True)