src/pydolphinscheduler/core/task.py [543:599]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    _DEFINE_ATTR = Task._DEFINE_ATTR | {"task_execute_type"}

    def __init__(
        self,
        name: str,
        task_type: str,
        description: str | None = None,
        flag: str | None = TaskFlag.YES,
        task_priority: str | None = TaskPriority.MEDIUM,
        worker_group: str | None = configuration.WORKFLOW_WORKER_GROUP,
        environment_name: str | None = None,
        task_group_id: int | None = 0,
        task_group_priority: int | None = 0,
        delay_time: int | None = 0,
        fail_retry_times: int | None = 0,
        fail_retry_interval: int | None = 1,
        timeout_notify_strategy: str | None = None,
        timeout: timedelta | int | None = None,
        workflow: Workflow | None = None,
        resource_list: list | None = None,
        dependence: dict | None = None,
        wait_start_timeout: dict | None = None,
        condition_result: dict | None = None,
        resource_plugin: ResourcePlugin | None = None,
        is_cache: bool | None = False,
        input_params: dict | None = None,
        output_params: dict | None = None,
        *args,
        **kwargs,
    ):
        super().__init__(
            name,
            task_type,
            description,
            flag,
            task_priority,
            worker_group,
            environment_name,
            task_group_id,
            task_group_priority,
            delay_time,
            fail_retry_times,
            fail_retry_interval,
            timeout_notify_strategy,
            timeout,
            workflow,
            resource_list,
            dependence,
            wait_start_timeout,
            condition_result,
            resource_plugin,
            is_cache,
            input_params,
            output_params,
            *args,
            **kwargs,
        )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/pydolphinscheduler/core/task.py [632:688]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    _DEFINE_ATTR = Task._DEFINE_ATTR | {"task_execute_type"}

    def __init__(
        self,
        name: str,
        task_type: str,
        description: str | None = None,
        flag: str | None = TaskFlag.YES,
        task_priority: str | None = TaskPriority.MEDIUM,
        worker_group: str | None = configuration.WORKFLOW_WORKER_GROUP,
        environment_name: str | None = None,
        task_group_id: int | None = 0,
        task_group_priority: int | None = 0,
        delay_time: int | None = 0,
        fail_retry_times: int | None = 0,
        fail_retry_interval: int | None = 1,
        timeout_notify_strategy: str | None = None,
        timeout: timedelta | int | None = None,
        workflow: Workflow | None = None,
        resource_list: list | None = None,
        dependence: dict | None = None,
        wait_start_timeout: dict | None = None,
        condition_result: dict | None = None,
        resource_plugin: ResourcePlugin | None = None,
        is_cache: bool | None = False,
        input_params: dict | None = None,
        output_params: dict | None = None,
        *args,
        **kwargs,
    ):
        super().__init__(
            name,
            task_type,
            description,
            flag,
            task_priority,
            worker_group,
            environment_name,
            task_group_id,
            task_group_priority,
            delay_time,
            fail_retry_times,
            fail_retry_interval,
            timeout_notify_strategy,
            timeout,
            workflow,
            resource_list,
            dependence,
            wait_start_timeout,
            condition_result,
            resource_plugin,
            is_cache,
            input_params,
            output_params,
            *args,
            **kwargs,
        )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -