Sub Process

Task sub_process.

class pydolphinscheduler.tasks.sub_process.SubProcess(name: str, process_definition_name: str, *args, **kwargs)

Bases: Task

Task SubProcess object, declare behavior for SubProcess task to dolphinscheduler.

get_process_definition_info(process_definition_name: str) → Dict

Get process definition info from java gateway, contains process definition id, name, code.

_downstream_task_codes: Set[int]

_task_custom_attr: set = {'process_definition_code'}

_task_relation: Set[TaskRelation]

_upstream_task_codes: Set[int]

property process_definition_code: str

Get process definition code, a wrapper for get_process_definition_info().