You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ki...@apache.org on 2021/11/04 08:15:20 UTC
[dolphinscheduler] branch dev updated: Fix f-strings variable error
(#6677)
This is an automated email from the ASF dual-hosted git repository.
kirs 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 9fb6d6b Fix f-strings variable error (#6677)
9fb6d6b is described below
commit 9fb6d6ba9f52673386ebf26f124d28e5dc8a9af4
Author: Jiajie Zhong <zh...@hotmail.com>
AuthorDate: Thu Nov 4 16:15:16 2021 +0800
Fix f-strings variable error (#6677)
---
dolphinscheduler-python/pydolphinscheduler/examples/bulk_create.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/dolphinscheduler-python/pydolphinscheduler/examples/bulk_create.py b/dolphinscheduler-python/pydolphinscheduler/examples/bulk_create.py
index bb8ff19..74203a1 100644
--- a/dolphinscheduler-python/pydolphinscheduler/examples/bulk_create.py
+++ b/dolphinscheduler-python/pydolphinscheduler/examples/bulk_create.py
@@ -40,12 +40,12 @@ for wf in range(0, NUM_WORKFLOWS):
with ProcessDefinition(name=workflow_name, tenant=TENANT) as pd:
for t in range(0, NUM_TASKS):
- task_name = f"task:{t}-workflow:{wf}"
+ task_name = f"task:{t}-{workflow_name}"
command = f"echo This is task {task_name}"
task = Shell(name=task_name, command=command)
if IS_CHAIN and t > 0:
- pre_task_name = f"task:{t-1}-wf:{wf}"
+ pre_task_name = f"task:{t-1}-{workflow_name}"
pd.get_one_task_by_name(pre_task_name) >> task
# We just submit workflow and task definition without set schedule time or run it manually