diff --git a/backend/btrixcloud/uploads.py b/backend/btrixcloud/uploads.py index 8ae51a9107..96dc33342e 100644 --- a/backend/btrixcloud/uploads.py +++ b/backend/btrixcloud/uploads.py @@ -190,10 +190,9 @@ async def _create_upload( self.event_webhook_ops.create_upload_finished_notification(crawl_id, org.id) ) - await self.page_ops.add_crawl_pages_to_db_from_wacz(crawl_id) - - if collections: - await self.colls.update_crawl_collections(crawl_id) + asyncio.create_task( + self._add_pages_and_update_collections(crawl_id, collections) + ) await self.orgs.inc_org_bytes_stored(org.id, file_size, "upload") @@ -207,6 +206,13 @@ async def _create_upload( return {"id": crawl_id, "added": True, "storageQuotaReached": quota_reached} + async def _add_pages_and_update_collections( + crawl_id: str, collections: Optional[List[str]] = None + ): + await self.page_ops.add_crawl_pages_to_db_from_wacz(crawl_id) + if collections: + await self.colls.update_crawl_collections(crawl_id) + async def delete_uploads( self, delete_list: DeleteCrawlList,