This is an automated email from the ASF dual-hosted git repository.
zhongjiajie pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new fd6eb1f [python] Correct python import syntax in example (#7617)
fd6eb1f is described below
commit fd6eb1f830dd60c5363971e735135afc06925380
Author: Jiajie Zhong <[email protected]>
AuthorDate: Fri Dec 24 20:07:49 2021 +0800
[python] Correct python import syntax in example (#7617)
fix: #7615
---
.../pydolphinscheduler/examples/task_dependent_example.py | 3 +--
.../pydolphinscheduler/examples/task_switch_example.py | 3 +--
2 files changed, 2 insertions(+), 4 deletions(-)
diff --git
a/dolphinscheduler-python/pydolphinscheduler/examples/task_dependent_example.py
b/dolphinscheduler-python/pydolphinscheduler/examples/task_dependent_example.py
index 255d599..68f2a57 100644
---
a/dolphinscheduler-python/pydolphinscheduler/examples/task_dependent_example.py
+++
b/dolphinscheduler-python/pydolphinscheduler/examples/task_dependent_example.py
@@ -34,8 +34,7 @@ task_dependent:
task_dependent(this task dependent on task_dependent_external.task_1 and
task_dependent_external.task_2).
"""
-from constants import ProcessDefinitionDefault
-
+from pydolphinscheduler.constants import ProcessDefinitionDefault
from pydolphinscheduler.core.process_definition import ProcessDefinition
from pydolphinscheduler.tasks.dependent import And, Dependent, DependentItem,
Or
from pydolphinscheduler.tasks.shell import Shell
diff --git
a/dolphinscheduler-python/pydolphinscheduler/examples/task_switch_example.py
b/dolphinscheduler-python/pydolphinscheduler/examples/task_switch_example.py
index 418d569..5ab2aa5 100644
--- a/dolphinscheduler-python/pydolphinscheduler/examples/task_switch_example.py
+++ b/dolphinscheduler-python/pydolphinscheduler/examples/task_switch_example.py
@@ -29,10 +29,9 @@ parent -> switch ->
.
"""
-from tasks.switch import Branch, Default, Switch, SwitchCondition
-
from pydolphinscheduler.core.process_definition import ProcessDefinition
from pydolphinscheduler.tasks.shell import Shell
+from pydolphinscheduler.tasks.switch import Branch, Default, Switch,
SwitchCondition
with ProcessDefinition(
name="task_dependent_external",
