revert accidental changes

Author: maxjakob

examples/bulk-ingest/bulk-ingest.py

@@ -6,14 +6,13 @@
 """Script that downloads a public dataset and streams it to an Elasticsearch cluster"""
 
 import csv
-from os.path import abspath, dirname, exists, join
-
+from os.path import abspath, join, dirname, exists
 import tqdm
 import urllib3
-
 from elasticsearch import Elasticsearch
 from elasticsearch.helpers import streaming_bulk
 
+
 NYC_RESTAURANTS = (
     "https://data.cityofnewyork.us/api/views/43nn-pn8j/rows.csv?accessType=DOWNLOAD"
 )
@@ -100,9 +99,7 @@ def main():
     progress = tqdm.tqdm(unit="docs", total=number_of_docs)
     successes = 0
     for ok, action in streaming_bulk(
-        client=client,
-        index="nyc-restaurants",
-        actions=generate_actions(),
+        client=client, index="nyc-restaurants", actions=generate_actions(),
     ):
         progress.update(1)
         successes += ok

examples/fastapi-apm/app.py

@@ -2,16 +2,15 @@
 # Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
 # See the LICENSE file in the project root for more information
 
+import aiohttp
 import datetime
 import os
-
-import aiohttp
-from elasticapm.contrib.starlette import ElasticAPM, make_apm_client
 from fastapi import FastAPI
 from fastapi.encoders import jsonable_encoder
-
 from elasticsearch import AsyncElasticsearch, NotFoundError
 from elasticsearch.helpers import async_streaming_bulk
+from elasticapm.contrib.starlette import ElasticAPM, make_apm_client
+
 
 apm = make_apm_client(
     {"SERVICE_NAME": "fastapi-app", "SERVER_URL": "http://apm-server:8200"}
@@ -61,9 +60,7 @@ async def search(query):
 
 @app.get("/delete")
 async def delete():
-    return await client.delete_by_query(
-        index="games", body={"query": {"match_all": {}}}
-    )
+    return await client.delete_by_query(index="games", body={"query": {"match_all": {}}})
 
 
 @app.get("/delete/{id}")

examples/fastapi-apm/ping.py

@@ -3,9 +3,9 @@
 # See the LICENSE file in the project root for more information
 
 import random
+import urllib3
 import time
 
-import urllib3
 
 endpoints = [
     "http://app:9292/",