From aed76777fdbc0513c22fe0d6f59b769d76ee23e9 Mon Sep 17 00:00:00 2001 From: Christian Stefanescu Date: Thu, 7 Dec 2023 15:07:55 +0100 Subject: [PATCH] Fix formatting --- aleph/logic/processing.py | 4 +++- aleph/manage.py | 7 ++++++- aleph/views/collections_api.py | 7 ++++++- 3 files changed, 15 insertions(+), 3 deletions(-) diff --git a/aleph/logic/processing.py b/aleph/logic/processing.py index ed2000e1d3..b7ca2d0875 100644 --- a/aleph/logic/processing.py +++ b/aleph/logic/processing.py @@ -27,7 +27,9 @@ def index_many(stage, collection, sync=False, entity_ids=None, batch=BATCH_SIZE) refresh_collection(collection.id) -def bulk_write(collection, entities, safe=False, role_id=None, mutable=True, clean=True): +def bulk_write( + collection, entities, safe=False, role_id=None, mutable=True, clean=True +): """Write a set of entities - given as dicts - to the index.""" # This is called mainly by the /api/2/collections/X/_bulk API. aggregator = get_aggregator(collection) diff --git a/aleph/manage.py b/aleph/manage.py index 8a32b70dba..2ef69b66de 100644 --- a/aleph/manage.py +++ b/aleph/manage.py @@ -276,7 +276,12 @@ def read_entities(): role = Role.load_cli_user() for _ in bulk_write( - collection, read_entities(), safe=safe, mutable=mutable, clean=clean, role_id=role.id + collection, + read_entities(), + safe=safe, + mutable=mutable, + clean=clean, + role_id=role.id, ): pass reindex_collection(collection) diff --git a/aleph/views/collections_api.py b/aleph/views/collections_api.py index c502892fbe..2e6f6b9ba7 100644 --- a/aleph/views/collections_api.py +++ b/aleph/views/collections_api.py @@ -284,7 +284,12 @@ def bulk(collection_id): entities = ensure_list(request.get_json(force=True)) entity_ids = list() for entity_id in bulk_write( - collection, entities, safe=safe, mutable=mutable, clean=clean, role_id=request.authz.id + collection, + entities, + safe=safe, + mutable=mutable, + clean=clean, + role_id=request.authz.id, ): entity_ids.append(entity_id) if entityset is not None: