Black fix

Author: ssadhu-sl

src/config.py

@@ -8,8 +8,9 @@ class config:
     collection_bucket = os.environ.get("COLLECTION_BUCKET", "local-collection-data")
     issues_base_path = os.environ.get("ISSUES_BASE_PATH", "log/issue")
     performance_base_path = os.environ.get("PERFORMANCE_BASE_PATH", "data/performance")
-    specification_base_path = os.environ.get("SPECIFICATION_BASE_PATH", "data/specification")
+    specification_base_path = os.environ.get(
+        "SPECIFICATION_BASE_PATH", "data/specification"
+    )
     use_aws_credential_chain = (
         os.environ.get("USE_AWS_CREDENTIAL_CHAIN", "true").lower() == "true"
     )
-

src/db.py

@@ -7,6 +7,7 @@
 
 logger = get_logger(__name__)
 
+
 def search_issues(params: IssuesParams):
     s3_uri = f"s3://{config.collection_bucket}/{config.issues_base_path}/**/*.parquet"
     pagination = f"LIMIT {params.limit} OFFSET {params.offset}"
@@ -52,6 +53,7 @@ def search_issues(params: IssuesParams):
             )
             raise e
 
+
 def search_provision_summary(params: ProvisionParams):
     s3_uri = f"s3://{config.collection_bucket}/{config.performance_base_path}/*.parquet"
     pagination = f"LIMIT {params.limit} OFFSET {params.offset}"
@@ -60,8 +62,10 @@ def search_provision_summary(params: ProvisionParams):
     if params.dataset:
         where_clause += _add_condition(where_clause, f"dataset = '{params.dataset}'")
     if params.organisation:
-        where_clause += _add_condition(where_clause, f"organisation = '{params.organisation}'")
-   
+        where_clause += _add_condition(
+            where_clause, f"organisation = '{params.organisation}'"
+        )
+
     sql_count = f"SELECT COUNT(*) FROM '{s3_uri}' {where_clause}"
     logger.debug(sql_count)
     sql_results = f"SELECT * FROM '{s3_uri}' {where_clause} {pagination}"

src/main.py

@@ -51,6 +51,7 @@ def issues(http_response: Response, params: IssuesParams = Depends()):
         headers=http_response.headers,
     )
 
+
 @app.get("/provision/provision_summary", tags=["provision_summary"])
 def provision_summary(http_response: Response, params: ProvisionParams = Depends()):
     paginated_result = db.search_provision_summary(params)
@@ -65,6 +66,7 @@ def provision_summary(http_response: Response, params: ProvisionParams = Depends
         headers=http_response.headers,
     )
 
+
 @app.get("/health", response_model=HealthCheckResponse, tags=["Health"])
 def healthcheck():
     return HealthCheckResponse(name="pipeline-api", version=app.version)

src/schema.py

@@ -33,6 +33,7 @@ class Issue(BaseModel):
     value: str
     message: str
 
+
 class ProvisionParams(BaseModel):
     offset: int = Field(0, ge=0)
     limit: int = Field(50, ge=1, le=100)