precommit linting

elser-speedtest/_support/filter_vocab.py

@@ -8,11 +8,9 @@
     lines = raw_vocab.readlines()
 
 
-l2 = ['"'+s.strip()+'"' for s in lines if pattern.match(s)]
+l2 = ['"' + s.strip() + '"' for s in lines if pattern.match(s)]
 
 with open("bert_vocab_whole_words.json", "w") as outfile:
     outfile.write("[")
     outfile.write(",".join(l2))
     outfile.write("]")
-
-

elser-speedtest/_support/generate_fixed_length_docs.py

@@ -13,4 +13,3 @@
         doc = {"body": " ".join(doc_words)}
 
         doc_file.writelines([json.dumps(doc), "\n"])
-`

elser-speedtest/_support/google-storage-uploader.py

@@ -10,4 +10,4 @@
 # Creates the new bucket
 bucket = storage_client.create_bucket(bucket_name)
 
-print(f"Bucket {bucket.name} created.")
+print(f"Bucket {bucket.name} created.")

elser-speedtest/track.py

@@ -23,9 +23,9 @@ def __init__(self, track, params):
 
 async def get_xpack_capabilities(es):
     print()
-    print("="*50)
+    print("=" * 50)
     print(await es.perform_request(method="GET", path="/_xpack"))
-    print("="*50)
+    print("=" * 50)
 
 
 elser_model_id = ".elser_model_1"
@@ -112,7 +112,7 @@ async def start_trained_model_deployment(es, params):
             number_of_allocations=number_of_allocations,
             threads_per_allocation=threads_per_allocation,
             queue_capacity=queue_capacity,
-            cache_size="0b"
+            cache_size="0b",
         )
         return True
     except BadRequestError as bre: