Underground-Digital/Workflow-Engine

1from flask_restful import Resource, marshal_with, reqparse2from flask_restful.inputs import int_range3 4from controllers.console import api5from controllers.console.app.wraps import get_app_model6from controllers.console.wraps import account_initialization_required, setup_required7from fields.workflow_app_log_fields import workflow_app_log_pagination_fields8from libs.login import login_required9from models import App10from models.model import AppMode11from services.workflow_app_service import WorkflowAppService12 13 14class WorkflowAppLogApi(Resource):15    @setup_required16    @login_required17    @account_initialization_required18    @get_app_model(mode=[AppMode.WORKFLOW])19    @marshal_with(workflow_app_log_pagination_fields)20    def get(self, app_model: App):21        """22        Get workflow app logs23        """24        parser = reqparse.RequestParser()25        parser.add_argument("keyword", type=str, location="args")26        parser.add_argument("status", type=str, choices=["succeeded", "failed", "stopped"], location="args")27        parser.add_argument("page", type=int_range(1, 99999), default=1, location="args")28        parser.add_argument("limit", type=int_range(1, 100), default=20, location="args")29        args = parser.parse_args()30 31        # get paginate workflow app logs32        workflow_app_service = WorkflowAppService()33        workflow_app_log_pagination = workflow_app_service.get_paginate_workflow_app_logs(34            app_model=app_model, args=args35        )36 37        return workflow_app_log_pagination38 39 40api.add_resource(WorkflowAppLogApi, "/apps/<uuid:app_id>/workflow-app-logs")41