Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
DolphinScheduler
提交
1165afbd
DolphinScheduler
项目概览
apache
/
DolphinScheduler
上一次同步 1 年多
通知
704
Star
9572
Fork
3514
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
DolphinScheduler
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
未验证
提交
1165afbd
编写于
11月 04, 2021
作者:
J
Jiajie Zhong
提交者:
GitHub
11月 04, 2021
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[python] Add param workgroup to process definition (#6667)
上级
71047db3
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
8 addition
and
1 deletion
+8
-1
dolphinscheduler-python/pydolphinscheduler/src/pydolphinscheduler/core/process_definition.py
...heduler/src/pydolphinscheduler/core/process_definition.py
+5
-1
dolphinscheduler-python/pydolphinscheduler/tests/core/test_process_definition.py
.../pydolphinscheduler/tests/core/test_process_definition.py
+3
-0
未找到文件。
dolphinscheduler-python/pydolphinscheduler/src/pydolphinscheduler/core/process_definition.py
浏览文件 @
1165afbd
...
...
@@ -60,6 +60,7 @@ class ProcessDefinition(Base):
"description"
,
"_project"
,
"_tenant"
,
"worker_group"
,
"timeout"
,
"release_state"
,
"param"
,
...
...
@@ -76,6 +77,7 @@ class ProcessDefinition(Base):
project
:
Optional
[
str
]
=
ProcessDefinitionDefault
.
PROJECT
,
tenant
:
Optional
[
str
]
=
ProcessDefinitionDefault
.
TENANT
,
queue
:
Optional
[
str
]
=
ProcessDefinitionDefault
.
QUEUE
,
worker_group
:
Optional
[
str
]
=
ProcessDefinitionDefault
.
WORKER_GROUP
,
timeout
:
Optional
[
int
]
=
0
,
release_state
:
Optional
[
str
]
=
ProcessDefinitionReleaseState
.
ONLINE
,
param
:
Optional
[
List
]
=
None
...
...
@@ -85,6 +87,7 @@ class ProcessDefinition(Base):
self
.
_project
=
project
self
.
_tenant
=
tenant
self
.
_queue
=
queue
self
.
worker_group
=
worker_group
self
.
timeout
=
timeout
self
.
release_state
=
release_state
self
.
param
=
param
...
...
@@ -226,6 +229,7 @@ class ProcessDefinition(Base):
str
(
self
.
param
)
if
self
.
param
else
None
,
json
.
dumps
(
self
.
task_location
),
self
.
timeout
,
self
.
worker_group
,
self
.
_tenant
,
# TODO add serialization function
json
.
dumps
(
self
.
task_relation_json
),
...
...
@@ -244,6 +248,6 @@ class ProcessDefinition(Base):
self
.
_project
,
self
.
name
,
""
,
"default"
,
self
.
worker_group
,
24
*
3600
,
)
dolphinscheduler-python/pydolphinscheduler/tests/core/test_process_definition.py
浏览文件 @
1165afbd
...
...
@@ -49,6 +49,7 @@ def test_process_definition_key_attr(func):
ProcessDefinitionDefault
.
TENANT
,
ProcessDefinitionDefault
.
QUEUE
,
ProcessDefinitionDefault
.
USER_STATE
)),
(
"worker_group"
,
ProcessDefinitionDefault
.
WORKER_GROUP
),
(
"release_state"
,
ProcessDefinitionReleaseState
.
ONLINE
),
],
)
...
...
@@ -63,6 +64,7 @@ def test_process_definition_default_value(name, value):
[
(
"project"
,
Project
,
"project"
),
(
"tenant"
,
Tenant
,
"tenant"
),
(
"worker_group"
,
str
,
"worker_group"
),
],
)
def
test_process_definition_set_attr
(
name
,
cls
,
expect
):
...
...
@@ -78,6 +80,7 @@ def test_process_definition_to_dict_without_task():
"description"
:
None
,
"project"
:
ProcessDefinitionDefault
.
PROJECT
,
"tenant"
:
ProcessDefinitionDefault
.
TENANT
,
"workerGroup"
:
ProcessDefinitionDefault
.
WORKER_GROUP
,
"timeout"
:
0
,
"releaseState"
:
ProcessDefinitionReleaseState
.
ONLINE
,
"param"
:
None
,
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录