feat(workflows-api): add workflow api and supporting deployment script #454
cicd.yml
on: push
gitflow-enforcer
0s
deploy-to-dev
/
deploy
deploy-to-production
/
deploy
deploy-to-staging
/
deploy
Annotations
11 errors and 2 warnings
workflows_api/runtime/src/airflow_helpers.py#L93
F-string is missing placeholders (F541)
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/services.py#L42
"items": parse_obj_as(List[schemas.Ingestion], response["Items"]),
"next": response.get("LastEvaluatedKey"),
}
-class NotInDb(Exception):
- ...
+class NotInDb(Exception): ...
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/main.py#L41
contact={"url": "https://github.com/NASA-IMPACT/veda-backend"},
)
# "Datasets" interface (collections + item ingests from one input)
+
@workflows_app.post(
"/dataset/validate",
tags=["Dataset"],
dependencies=[Depends(auth.get_username)],
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/main.py#L99
return_dict["workflows_ids"] = workflow_runs # type: ignore
return return_dict
-
@workflows_app.post(
"/discovery",
response_model=schemas.WorkflowExecutionResponse,
tags=["Workflow-Executions"],
status_code=201,
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/main.py#L136
@workflows_app.get(
"/list-workflows",
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
"""
return airflow_helpers.list_dags()
|
workflows_api/runtime/src/airflow_helpers.py#L93
F-string is missing placeholders (F541)
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/services.py#L42
"items": parse_obj_as(List[schemas.Ingestion], response["Items"]),
"next": response.get("LastEvaluatedKey"),
}
-class NotInDb(Exception):
- ...
+class NotInDb(Exception): ...
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/main.py#L41
contact={"url": "https://github.com/NASA-IMPACT/veda-backend"},
)
# "Datasets" interface (collections + item ingests from one input)
+
@workflows_app.post(
"/dataset/validate",
tags=["Dataset"],
dependencies=[Depends(auth.get_username)],
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/main.py#L99
return_dict["workflows_ids"] = workflow_runs # type: ignore
return return_dict
-
@workflows_app.post(
"/discovery",
response_model=schemas.WorkflowExecutionResponse,
tags=["Workflow-Executions"],
status_code=201,
|
/home/runner/work/veda-data-airflow/veda-data-airflow/workflows_api/runtime/src/main.py#L136
@workflows_app.get(
"/list-workflows",
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
"""
return airflow_helpers.list_dags()
|
Run linters
Linting failures detected. See check runs with annotations for details.
|
Run linters
Node.js 16 actions are deprecated. Please update the following actions to use Node.js 20: actions/checkout@v2, actions/setup-python@v4, wearerequired/lint-action@v2. For more information see: https://github.blog/changelog/2023-09-22-github-actions-transitioning-from-node-16-to-node-20/.
|
Run linters
The following actions uses node12 which is deprecated and will be forced to run on node16: actions/checkout@v2. For more info: https://github.blog/changelog/2023-06-13-github-actions-all-actions-will-run-on-node16-instead-of-node12-by-default/
|