sailist commented on issue #138:
URL:
https://github.com/apache/dolphinscheduler-sdk-python/issues/138#issuecomment-1933333301
btw, sub workflow is also not worked properly, I workaround it by replace
definition of process_definition_code:
```python
class CustomSubWorkflow(Task):
"""Task SubWorkflow object, declare behavior for SubWorkflow task to
dolphinscheduler."""
_task_custom_attr = {"process_definition_code"}
def __init__(self, name: str, workflow_name: str, *args, **kwargs):
super().__init__(name, TaskType.SUB_WORKFLOW, *args, **kwargs)
self.workflow_name = workflow_name
@property
def process_definition_code(self) -> str:
"""Get workflow code, a wrapper for :func:`get_workflow_info`.
We can not change this function name to workflow_code, because it is
a keyword used in
dolphinscheduler itself.
"""
project_code = get_project(self.workflow.project.name)["code"]
return get_workflow(project_code, self.workflow_name)["code"]
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
