dag-executor-plugin-sdk 0.1.3

Plugin SDK for dag-executor — interfaces, types, and utilities for plugin development

dag-executor-plugin-sdk

Plugin SDK for dag-executor — interfaces, types, and utilities for plugin development.

Install

pip install dag-executor-plugin-sdk

Quick Start

from dag_executor_sdk import ITask, Subtask, PluginHookContext, register_task

@register_task("my_task")
class MyTask(ITask):
    async def _create_subtasks(self, params: dict) -> list[Subtask]:
        ...

    async def _execute_subtask(self, subtask: Subtask) -> dict:
        ...

License

MIT