Merge pull request #390 from OP-TED/feature/TED-1026

CaptainOfHacks · web-flow · commit 548c00d795d9 · 2022-11-29T14:35:47.000+02:00
Feature/ted 1026
diff --git a/ted_sws/data_manager/services/create_batch_collection_materialised_view.py b/ted_sws/data_manager/services/create_batch_collection_materialised_view.py
@@ -30,4 +30,4 @@ def create_batch_collection_materialised_view(mongo_client: MongoClient):
         {
             "$out": NOTICE_PROCESS_BATCH_COLLECTION_NAME
         }
-    ])
+    ], allowDiskUse=True)
diff --git a/ted_sws/data_manager/services/create_notice_collection_materialised_view.py b/ted_sws/data_manager/services/create_notice_collection_materialised_view.py
@@ -40,7 +40,7 @@ def create_notice_collection_materialised_view(mongo_client: MongoClient):
         {
             "$out": NOTICES_MATERIALISED_VIEW_NAME
         }
-    ])
+    ], allowDiskUse=True)
     materialised_view = database[NOTICES_MATERIALISED_VIEW_NAME]
     materialised_view.create_index([("created_at", DESCENDING)])
     materialised_view.create_index([("publication_date", DESCENDING)])
@@ -80,4 +80,4 @@ def create_notice_kpi_collection(mongo_client: MongoClient):
         {
             "$out": NOTICE_KPI_COLLECTION_NAME
         }
-    ])
+    ], allowDiskUse=True)

Original file line number	Diff line number	Diff line change
`@@ -30,4 +30,4 @@ def create_batch_collection_materialised_view(mongo_client: MongoClient):`
`30`	`30`	`{`
`31`	`31`	`"$out": NOTICE_PROCESS_BATCH_COLLECTION_NAME`
`32`	`32`	`}`
`33`		`- ])`
	`33`	`+ ], allowDiskUse=True)`
Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ def create_notice_collection_materialised_view(mongo_client: MongoClient):`
`40`	`40`	`{`
`41`	`41`	`"$out": NOTICES_MATERIALISED_VIEW_NAME`
`42`	`42`	`}`
`43`		`- ])`
	`43`	`+ ], allowDiskUse=True)`
`44`	`44`	`materialised_view = database[NOTICES_MATERIALISED_VIEW_NAME]`
`45`	`45`	`materialised_view.create_index([("created_at", DESCENDING)])`
`46`	`46`	`materialised_view.create_index([("publication_date", DESCENDING)])`
`@@ -80,4 +80,4 @@ def create_notice_kpi_collection(mongo_client: MongoClient):`
`80`	`80`	`{`
`81`	`81`	`"$out": NOTICE_KPI_COLLECTION_NAME`
`82`	`82`	`}`
`83`		`- ])`
	`83`	`+ ], allowDiskUse=True)`