v1.0.0 release

[ryanchao2012]

Migrate Task to new interface

class TaskAttribute:
    op_class: str = "EmptyOperator"
    op_module: str = None
    op_params: Dict[str, Any] = None
    upstream: TaskClass | Iterable[TaskClass, ...] = None
    downstream: TaskClass | Iterable[TaskClass, ...] = None


class Task(TaskAttribute):
    @classmethod
    def _get_taskid(cls):
        ...

    @classmethod        
    def _to_varname(cls):
        ...

    @classmethod
    def _to_ast(cls):
        ...

    @classmethod  # with cache
    def _get_attributes(cls):
        ...

    @classmethod
    def _resolve_operator(cls) -> Type:
        ...
    
    
AirFly = Task


class TaskPair:
    up: TaskClass
    down: TaskClass

    @classmethod
    def _to_ast(cls):
        ...

class TaskTree:
    taskset: Set[TaskClass]
    taskpairs: Set[TaskPair]

    @classmethod
    def from_module(cls, module: ModuleType):
        ...

    def to_dag(self, name: str, includes, dag_params, formatted=True) -> str:
        ...

    def _collect_taskset(cls):
        ...
        
    def _collect_taskpairs(cls):
        ...

    def _to_ast(self):
        ...

    def _build_header(self):
        ...

    def _build_imports(self):
        ...

    def _build_includes(self):
        ...

    def _build_dag_context(self):
        ...

[ryanchao2012]

plan to release on 2024/05/05 2024/05/10