lint

workflows_api/runtime/src/airflow_helpers.py

@@ -90,7 +90,7 @@ def list_dags() -> str:
         f"https://{mwaa_cli_token['WebServerHostname']}/aws_mwaa/cli"
     )
 
-    raw_data = f"dags list"
+    raw_data = "dags list"
     mwaa_response = requests.post(
         mwaa_webserver_hostname,
         headers={

workflows_api/runtime/src/config.py

@@ -17,7 +17,7 @@ class Settings(BaseSettings):
     client_secret: str = Field("", description="The Cognito APP client secret")
     stage: str = Field(description="API stage")
     workflow_root_path: str = Field(description="Root path of API")
-    ingest_root_path: str = Field(description="Root path of API")
+    ingest_url: str = Field(description="URL of ingest API")
 
     class Config(AwsSsmSourceConfig):
         env_file = ".env"

workflows_api/runtime/src/main.py

@@ -44,6 +44,7 @@
 
 # "Datasets" interface (collections + item ingests from one input)
 
+
 @workflows_app.post(
     "/dataset/validate",
     tags=["Dataset"],
@@ -101,7 +102,6 @@ async def publish_dataset(
     return return_dict
 
 
-
 @workflows_app.post(
     "/discovery",
     response_model=schemas.WorkflowExecutionResponse,
@@ -138,9 +138,9 @@ async def get_discovery_workflow_execution_status(
     tags=["Workflow-Executions"],
     dependencies=[Depends(auth.get_username)],
 )
-async def get_workflow_list() -> Union[
-    schemas.ExecutionResponse, schemas.WorkflowExecutionResponse
-]:
+async def get_workflow_list() -> (
+    Union[schemas.ExecutionResponse, schemas.WorkflowExecutionResponse]
+):
     """
     Returns the status of the workflow execution
     """

workflows_api/runtime/src/services.py

@@ -44,5 +44,5 @@ def fetch_many(
         }
 
 
-class NotInDb(Exception):
+class NotInDb(Exception): 
     ...