Skip to content

Commit 6692323

Browse files
committed
run pre-commit
1 parent cf47504 commit 6692323

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,14 @@
44

55
import attr
66
import elasticsearch
7-
from elasticsearch_dsl import Q, Search
87
from elasticsearch import helpers
8+
from elasticsearch_dsl import Q, Search
99

1010
from stac_fastapi.elasticsearch import serializers
1111
from stac_fastapi.elasticsearch.config import ElasticsearchSettings
1212
from stac_fastapi.types import stac as stac_types
13-
from stac_fastapi.types.errors import NotFoundError
14-
from stac_fastapi.types.stac import Collection, Collections, Item, ItemCollection
1513
from stac_fastapi.types.errors import ConflictError, ForeignKeyError, NotFoundError
14+
from stac_fastapi.types.stac import Collection, Collections, Item, ItemCollection
1615

1716
logger = logging.getLogger(__name__)
1817

@@ -315,4 +314,3 @@ def bulk_sync(self, processed_items):
315314
for item in processed_items
316315
]
317316
helpers.bulk(self.client, actions)
318-

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/transactions.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99

1010
from stac_fastapi.elasticsearch.config import ElasticsearchSettings
1111
from stac_fastapi.elasticsearch.database_logic import DatabaseLogic
12-
1312
from stac_fastapi.elasticsearch.serializers import CollectionSerializer, ItemSerializer
1413
from stac_fastapi.elasticsearch.session import Session
1514
from stac_fastapi.extensions.third_party.bulk_transactions import (
@@ -26,6 +25,7 @@
2625
@attr.s
2726
class TransactionsClient(BaseTransactionsClient):
2827
"""Transactions extension specific CRUD operations."""
28+
2929
session: Session = attr.ib(default=attr.Factory(Session.create_from_env))
3030
database = DatabaseLogic()
3131

@@ -60,7 +60,7 @@ def update_item(self, item: stac_types.Item, **kwargs) -> stac_types.Item:
6060
# todo: index instead of delete and create
6161
self.delete_item(item_id=item["id"], collection_id=item["collection"])
6262
self.create_item(item=item, **kwargs)
63-
63+
6464
return ItemSerializer.db_to_stac(item, base_url)
6565

6666
@overrides
@@ -91,7 +91,7 @@ def update_collection(
9191
) -> stac_types.Collection:
9292
"""Update collection."""
9393
base_url = str(kwargs["request"].base_url)
94-
94+
9595
self.database.prep_update_collection(collection_id=collection["id"])
9696
self.delete_collection(collection["id"])
9797
self.create_collection(collection, **kwargs)

0 commit comments

Comments
 (0)