run pre commit

Author: jonhealy1

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/transactions.py

@@ -60,7 +60,8 @@ def create_item(self, model: stac_types.Item, **kwargs):
         if model["type"] == "FeatureCollection":
             bulk_client = BulkTransactionsClient()
             processed_items = [
-                bulk_client._preprocess_item(item, base_url) for item in model["features"]
+                bulk_client._preprocess_item(item, base_url)
+                for item in model["features"]
             ]
             return_msg = f"Successfully added {len(processed_items)} items."
             bulk_client.bulk_sync(processed_items)
@@ -222,6 +223,7 @@ def _preprocess_item(self, model: stac_types.Item, base_url) -> stac_types.Item:
         return model
 
     def bulk_sync(self, processed_items):
+        """Elasticsearch bulk insertion."""
         actions = [
             {"_index": "stac_items", "_source": item} for item in processed_items
         ]

stac_fastapi/elasticsearch/tests/clients/test_elasticsearch.py

@@ -289,6 +289,7 @@ def test_bulk_item_insert(
     #         item["id"], item["collection"], request=MockStarletteRequest
     #     )
 
+
 def test_feature_collection_insert(
     es_core: CoreCrudClient,
     es_transactions: TransactionsClient,
@@ -299,23 +300,21 @@ def test_feature_collection_insert(
     es_transactions.create_collection(coll, request=MockStarletteRequest)
 
     item = load_test_data("test_item.json")
- 
+
     features = []
     for _ in range(10):
         _item = deepcopy(item)
         _item["id"] = str(uuid.uuid4())
         features.append(_item)
 
-    feature_collection = {
-        "type": "FeatureCollection",
-        "features": features
-    }
+    feature_collection = {"type": "FeatureCollection", "features": features}
 
     es_transactions.create_item(feature_collection, request=MockStarletteRequest)
     time.sleep(3)
     fc = es_core.item_collection(coll["id"], request=MockStarletteRequest)
     assert len(fc["features"]) >= 10
 
+
 @pytest.mark.skip(reason="Not working")
 def test_landing_page_no_collection_title(
     es_core: CoreCrudClient,