ai-flow-python/app/service/task/base_task.py

from abc import ABC, abstractmethod

from app.service.task.task_param import TaskParam
from app.service.task.task_result import TaskResult


class BaseTask(ABC):
    @abstractmethod
    def get_type(self) -> str:
        ...

    @abstractmethod
    def execute(self, param: TaskParam) -> TaskResult:
        ...