linted with isort

src/check-ins/check_in_model.py

@@ -1,6 +1,7 @@
-from pydantic import BaseModel
 from datetime import datetime
 
+from pydantic import BaseModel
+
 
 class CheckIn(BaseModel):
     coffee_shop_id: int | None

src/check-ins/check_ins_service.py

@@ -1,8 +1,9 @@
-from fastapi import HTTPException
-from persistence import Client
+import random
+
 import requests
 import utils
-import random
+from fastapi import HTTPException
+from persistence import Client
 
 conn = Client(random.choice(utils.get_consul_kv("check_ins_cluster_nodes")))
 

src/check-ins/controller.py

@@ -1,9 +1,10 @@
 from contextlib import asynccontextmanager
-import check_ins_service
 from typing import Annotated
-from check_in_model import CheckIn
-from fastapi import FastAPI, HTTPException, Cookie
+
+import check_ins_service
 import utils
+from check_in_model import CheckIn
+from fastapi import Cookie, FastAPI, HTTPException
 
 
 @asynccontextmanager

src/check-ins/persistence.py

@@ -1,6 +1,7 @@
+from typing import Dict, Literal
+
 from cassandra.cluster import Cluster, Session
 from cassandra.query import dict_factory
-from typing import Dict, Literal
 
 
 class Client:

src/check-ins/utils.py

@@ -1,10 +1,11 @@
+import json
 import os
 import random
 import socket
-from kafka.producer import KafkaProducer
-import json
 from datetime import datetime
 
+from kafka.producer import KafkaProducer
+
 import consul
 
 

src/coffee-packs/utils.py

@@ -1,13 +1,13 @@
+import json
 import os
 import random
 import socket
-import json
 from datetime import datetime
+
 from kafka.producer import KafkaProducer
 
 import consul
 
-
 consul_addr = os.getenv("CONSUL_ADDR").split(":")
 c = consul.Consul(host=consul_addr[0], port=int(consul_addr[1]))
 HTTP_PREFIX = "http://"

src/coffee-shops/utils.py

@@ -1,9 +1,10 @@
+import json
 import os
 import random
 import socket
-from kafka.producer import KafkaProducer
 from datetime import datetime
-import json
+
+from kafka.producer import KafkaProducer
 
 import consul