emrstudio-20231009/alibabacloud_emrstudio20231009/models.py (2,183 lines of code) (raw):
# -*- coding: utf-8 -*-
# This file is auto-generated, don't edit it. Thanks.
from Tea.model import TeaModel
class DescribeManualTaskRequest(TeaModel):
def __init__(self, workspace_id=None):
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeManualTaskRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class DescribeManualTaskResponseBody(TeaModel):
def __init__(self, create_time=None, description=None, manual_task_id=None, manual_task_name=None,
parent_directory_id=None, project_id=None, resource_ids=None, task_params=None, task_type=None, update_time=None,
request_id=None):
# 代表创建时间的资源属性字段
self.create_time = create_time # type: str
# 描述
self.description = description # type: str
# 代表资源一级ID的资源属性字段
self.manual_task_id = manual_task_id # type: str
# 代表资源名称的资源属性字段
self.manual_task_name = manual_task_name # type: str
# 目录ID
self.parent_directory_id = parent_directory_id # type: str
# 项目ID
self.project_id = project_id # type: str
# 资源id列表
self.resource_ids = resource_ids # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务类型
self.task_type = task_type # type: str
# 更新时间
self.update_time = update_time # type: str
# Id of the request
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeManualTaskResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.create_time is not None:
result['CreateTime'] = self.create_time
if self.description is not None:
result['Description'] = self.description
if self.manual_task_id is not None:
result['ManualTaskId'] = self.manual_task_id
if self.manual_task_name is not None:
result['ManualTaskName'] = self.manual_task_name
if self.parent_directory_id is not None:
result['ParentDirectoryId'] = self.parent_directory_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.resource_ids is not None:
result['ResourceIds'] = self.resource_ids
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_type is not None:
result['TaskType'] = self.task_type
if self.update_time is not None:
result['UpdateTime'] = self.update_time
if self.request_id is not None:
result['requestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('ManualTaskId') is not None:
self.manual_task_id = m.get('ManualTaskId')
if m.get('ManualTaskName') is not None:
self.manual_task_name = m.get('ManualTaskName')
if m.get('ParentDirectoryId') is not None:
self.parent_directory_id = m.get('ParentDirectoryId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('ResourceIds') is not None:
self.resource_ids = m.get('ResourceIds')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
return self
class DescribeManualTaskResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeManualTaskResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeManualTaskResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeManualTaskResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeManualTaskInstanceRequest(TeaModel):
def __init__(self, workspace_id=None):
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeManualTaskInstanceRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class DescribeManualTaskInstanceResponseBody(TeaModel):
def __init__(self, emr_cluster_id=None, end_time=None, external_app_id=None, manual_task_instance_id=None,
manual_task_instance_name=None, resource_group_id=None, start_time=None, status=None, submit_time=None, task_params=None,
task_type=None, request_id=None):
# EMR集群ID
self.emr_cluster_id = emr_cluster_id # type: str
# 结束时间
self.end_time = end_time # type: str
# 外部应用ID
self.external_app_id = external_app_id # type: str
# 代表资源一级ID的资源属性字段
self.manual_task_instance_id = manual_task_instance_id # type: str
# 代表资源名称的资源属性字段
self.manual_task_instance_name = manual_task_instance_name # type: str
# 资源组ID
self.resource_group_id = resource_group_id # type: str
# 开始时间
self.start_time = start_time # type: str
# 状态
self.status = status # type: str
# 提交时间
self.submit_time = submit_time # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务类型
self.task_type = task_type # type: str
# Id of the request
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeManualTaskInstanceResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.emr_cluster_id is not None:
result['EmrClusterId'] = self.emr_cluster_id
if self.end_time is not None:
result['EndTime'] = self.end_time
if self.external_app_id is not None:
result['ExternalAppId'] = self.external_app_id
if self.manual_task_instance_id is not None:
result['ManualTaskInstanceId'] = self.manual_task_instance_id
if self.manual_task_instance_name is not None:
result['ManualTaskInstanceName'] = self.manual_task_instance_name
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.start_time is not None:
result['StartTime'] = self.start_time
if self.status is not None:
result['Status'] = self.status
if self.submit_time is not None:
result['SubmitTime'] = self.submit_time
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_type is not None:
result['TaskType'] = self.task_type
if self.request_id is not None:
result['requestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('EmrClusterId') is not None:
self.emr_cluster_id = m.get('EmrClusterId')
if m.get('EndTime') is not None:
self.end_time = m.get('EndTime')
if m.get('ExternalAppId') is not None:
self.external_app_id = m.get('ExternalAppId')
if m.get('ManualTaskInstanceId') is not None:
self.manual_task_instance_id = m.get('ManualTaskInstanceId')
if m.get('ManualTaskInstanceName') is not None:
self.manual_task_instance_name = m.get('ManualTaskInstanceName')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('StartTime') is not None:
self.start_time = m.get('StartTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('SubmitTime') is not None:
self.submit_time = m.get('SubmitTime')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
return self
class DescribeManualTaskInstanceResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeManualTaskInstanceResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeManualTaskInstanceResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeManualTaskInstanceResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeProjectRequest(TeaModel):
def __init__(self, workspace_id=None):
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeProjectRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class DescribeProjectResponseBody(TeaModel):
def __init__(self, code=None, description=None, name=None, request_id=None):
self.code = code # type: long
self.description = description # type: str
self.name = name # type: str
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeProjectResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.code is not None:
result['code'] = self.code
if self.description is not None:
result['description'] = self.description
if self.name is not None:
result['name'] = self.name
if self.request_id is not None:
result['requestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('code') is not None:
self.code = m.get('code')
if m.get('description') is not None:
self.description = m.get('description')
if m.get('name') is not None:
self.name = m.get('name')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
return self
class DescribeProjectResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeProjectResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeProjectResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeProjectResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeTaskRequest(TeaModel):
def __init__(self, workspace_id=None):
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeTaskRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class DescribeTaskResponseBody(TeaModel):
def __init__(self, create_time=None, delay_time=None, description=None, fail_retry_interval=None,
fail_retry_times=None, flag=None, project_id=None, resource_ids=None, task_id=None, task_name=None, task_params=None,
task_priority=None, task_type=None, timeout=None, timeout_flag=None, timeout_notify_strategy=None,
update_time=None, version=None, request_id=None):
# 代表创建时间的资源属性字段
self.create_time = create_time # type: str
# 延时执行时间
self.delay_time = delay_time # type: int
# 描述
self.description = description # type: str
# 失败重试间隔
self.fail_retry_interval = fail_retry_interval # type: int
# 失败重试次数
self.fail_retry_times = fail_retry_times # type: int
# 运行标志
self.flag = flag # type: str
# 项目ID
self.project_id = project_id # type: str
# 资源ID列表
self.resource_ids = resource_ids # type: str
# 代表资源一级ID的资源属性字段
self.task_id = task_id # type: str
# 代表资源名称的资源属性字段
self.task_name = task_name # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务优先级
self.task_priority = task_priority # type: str
# 任务类型
self.task_type = task_type # type: str
# 超时时长
self.timeout = timeout # type: int
# 超时告警标志
self.timeout_flag = timeout_flag # type: str
# 超时告警标志
self.timeout_notify_strategy = timeout_notify_strategy # type: str
# 更新时间
self.update_time = update_time # type: str
# 版本
self.version = version # type: str
# Id of the request
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeTaskResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.create_time is not None:
result['CreateTime'] = self.create_time
if self.delay_time is not None:
result['DelayTime'] = self.delay_time
if self.description is not None:
result['Description'] = self.description
if self.fail_retry_interval is not None:
result['FailRetryInterval'] = self.fail_retry_interval
if self.fail_retry_times is not None:
result['FailRetryTimes'] = self.fail_retry_times
if self.flag is not None:
result['Flag'] = self.flag
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.resource_ids is not None:
result['ResourceIds'] = self.resource_ids
if self.task_id is not None:
result['TaskId'] = self.task_id
if self.task_name is not None:
result['TaskName'] = self.task_name
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_priority is not None:
result['TaskPriority'] = self.task_priority
if self.task_type is not None:
result['TaskType'] = self.task_type
if self.timeout is not None:
result['Timeout'] = self.timeout
if self.timeout_flag is not None:
result['TimeoutFlag'] = self.timeout_flag
if self.timeout_notify_strategy is not None:
result['TimeoutNotifyStrategy'] = self.timeout_notify_strategy
if self.update_time is not None:
result['UpdateTime'] = self.update_time
if self.version is not None:
result['Version'] = self.version
if self.request_id is not None:
result['requestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('DelayTime') is not None:
self.delay_time = m.get('DelayTime')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('FailRetryInterval') is not None:
self.fail_retry_interval = m.get('FailRetryInterval')
if m.get('FailRetryTimes') is not None:
self.fail_retry_times = m.get('FailRetryTimes')
if m.get('Flag') is not None:
self.flag = m.get('Flag')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('ResourceIds') is not None:
self.resource_ids = m.get('ResourceIds')
if m.get('TaskId') is not None:
self.task_id = m.get('TaskId')
if m.get('TaskName') is not None:
self.task_name = m.get('TaskName')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskPriority') is not None:
self.task_priority = m.get('TaskPriority')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
if m.get('Timeout') is not None:
self.timeout = m.get('Timeout')
if m.get('TimeoutFlag') is not None:
self.timeout_flag = m.get('TimeoutFlag')
if m.get('TimeoutNotifyStrategy') is not None:
self.timeout_notify_strategy = m.get('TimeoutNotifyStrategy')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
if m.get('Version') is not None:
self.version = m.get('Version')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
return self
class DescribeTaskResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeTaskResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeTaskResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeTaskResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeTaskInstanceRequest(TeaModel):
def __init__(self, workspace_id=None):
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeTaskInstanceRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class DescribeTaskInstanceResponseBody(TeaModel):
def __init__(self, dry_run=None, emr_cluster_id=None, end_time=None, external_app_id=None,
resource_group_id=None, retry_times=None, start_time=None, status=None, submit_time=None, task_id=None,
task_instance_id=None, task_instance_name=None, task_params=None, task_type=None, task_version=None,
workflow_instance_id=None, request_id=None):
# 空跑标识
self.dry_run = dry_run # type: str
# EMR集群ID
self.emr_cluster_id = emr_cluster_id # type: str
# 结束时间
self.end_time = end_time # type: str
# 外部应用ID
self.external_app_id = external_app_id # type: str
# 资源组ID
self.resource_group_id = resource_group_id # type: str
# 重试次数
self.retry_times = retry_times # type: int
# 开始时间
self.start_time = start_time # type: str
# 状态
self.status = status # type: str
# 提交时间
self.submit_time = submit_time # type: str
# 任务ID
self.task_id = task_id # type: str
# 任务实例ID
self.task_instance_id = task_instance_id # type: str
# 任务实例名称
self.task_instance_name = task_instance_name # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务类型
self.task_type = task_type # type: str
# 任务版本
self.task_version = task_version # type: str
# 工作流实例ID
self.workflow_instance_id = workflow_instance_id # type: str
# Id of the request
self.request_id = request_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(DescribeTaskInstanceResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.dry_run is not None:
result['DryRun'] = self.dry_run
if self.emr_cluster_id is not None:
result['EmrClusterId'] = self.emr_cluster_id
if self.end_time is not None:
result['EndTime'] = self.end_time
if self.external_app_id is not None:
result['ExternalAppId'] = self.external_app_id
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.retry_times is not None:
result['RetryTimes'] = self.retry_times
if self.start_time is not None:
result['StartTime'] = self.start_time
if self.status is not None:
result['Status'] = self.status
if self.submit_time is not None:
result['SubmitTime'] = self.submit_time
if self.task_id is not None:
result['TaskId'] = self.task_id
if self.task_instance_id is not None:
result['TaskInstanceId'] = self.task_instance_id
if self.task_instance_name is not None:
result['TaskInstanceName'] = self.task_instance_name
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_type is not None:
result['TaskType'] = self.task_type
if self.task_version is not None:
result['TaskVersion'] = self.task_version
if self.workflow_instance_id is not None:
result['WorkflowInstanceId'] = self.workflow_instance_id
if self.request_id is not None:
result['requestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('DryRun') is not None:
self.dry_run = m.get('DryRun')
if m.get('EmrClusterId') is not None:
self.emr_cluster_id = m.get('EmrClusterId')
if m.get('EndTime') is not None:
self.end_time = m.get('EndTime')
if m.get('ExternalAppId') is not None:
self.external_app_id = m.get('ExternalAppId')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('RetryTimes') is not None:
self.retry_times = m.get('RetryTimes')
if m.get('StartTime') is not None:
self.start_time = m.get('StartTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('SubmitTime') is not None:
self.submit_time = m.get('SubmitTime')
if m.get('TaskId') is not None:
self.task_id = m.get('TaskId')
if m.get('TaskInstanceId') is not None:
self.task_instance_id = m.get('TaskInstanceId')
if m.get('TaskInstanceName') is not None:
self.task_instance_name = m.get('TaskInstanceName')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
if m.get('TaskVersion') is not None:
self.task_version = m.get('TaskVersion')
if m.get('WorkflowInstanceId') is not None:
self.workflow_instance_id = m.get('WorkflowInstanceId')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
return self
class DescribeTaskInstanceResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeTaskInstanceResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeTaskInstanceResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeTaskInstanceResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeWorkflowRequest(TeaModel):
def __init__(self, workspace_id=None):
self.workspace_id = workspace_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(DescribeWorkflowRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class DescribeWorkflowResponseBodyTaskRelations(TeaModel):
def __init__(self, name=None, post_task_id=None, post_task_version=None, pre_task_id=None,
pre_task_version=None):
self.name = name # type: str
self.post_task_id = post_task_id # type: long
self.post_task_version = post_task_version # type: int
self.pre_task_id = pre_task_id # type: long
self.pre_task_version = pre_task_version # type: int
def validate(self):
pass
def to_map(self):
_map = super(DescribeWorkflowResponseBodyTaskRelations, self).to_map()
if _map is not None:
return _map
result = dict()
if self.name is not None:
result['name'] = self.name
if self.post_task_id is not None:
result['postTaskId'] = self.post_task_id
if self.post_task_version is not None:
result['postTaskVersion'] = self.post_task_version
if self.pre_task_id is not None:
result['preTaskId'] = self.pre_task_id
if self.pre_task_version is not None:
result['preTaskVersion'] = self.pre_task_version
return result
def from_map(self, m=None):
m = m or dict()
if m.get('name') is not None:
self.name = m.get('name')
if m.get('postTaskId') is not None:
self.post_task_id = m.get('postTaskId')
if m.get('postTaskVersion') is not None:
self.post_task_version = m.get('postTaskVersion')
if m.get('preTaskId') is not None:
self.pre_task_id = m.get('preTaskId')
if m.get('preTaskVersion') is not None:
self.pre_task_version = m.get('preTaskVersion')
return self
class DescribeWorkflowResponseBodyTasks(TeaModel):
def __init__(self, description=None, name=None, task_id=None, version=None):
self.description = description # type: str
self.name = name # type: str
self.task_id = task_id # type: long
self.version = version # type: int
def validate(self):
pass
def to_map(self):
_map = super(DescribeWorkflowResponseBodyTasks, self).to_map()
if _map is not None:
return _map
result = dict()
if self.description is not None:
result['description'] = self.description
if self.name is not None:
result['name'] = self.name
if self.task_id is not None:
result['taskId'] = self.task_id
if self.version is not None:
result['version'] = self.version
return result
def from_map(self, m=None):
m = m or dict()
if m.get('description') is not None:
self.description = m.get('description')
if m.get('name') is not None:
self.name = m.get('name')
if m.get('taskId') is not None:
self.task_id = m.get('taskId')
if m.get('version') is not None:
self.version = m.get('version')
return self
class DescribeWorkflowResponseBody(TeaModel):
def __init__(self, request_id=None, task_relations=None, tasks=None):
self.request_id = request_id # type: str
self.task_relations = task_relations # type: list[DescribeWorkflowResponseBodyTaskRelations]
self.tasks = tasks # type: list[DescribeWorkflowResponseBodyTasks]
def validate(self):
if self.task_relations:
for k in self.task_relations:
if k:
k.validate()
if self.tasks:
for k in self.tasks:
if k:
k.validate()
def to_map(self):
_map = super(DescribeWorkflowResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.request_id is not None:
result['requestId'] = self.request_id
result['taskRelations'] = []
if self.task_relations is not None:
for k in self.task_relations:
result['taskRelations'].append(k.to_map() if k else None)
result['tasks'] = []
if self.tasks is not None:
for k in self.tasks:
result['tasks'].append(k.to_map() if k else None)
return result
def from_map(self, m=None):
m = m or dict()
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
self.task_relations = []
if m.get('taskRelations') is not None:
for k in m.get('taskRelations'):
temp_model = DescribeWorkflowResponseBodyTaskRelations()
self.task_relations.append(temp_model.from_map(k))
self.tasks = []
if m.get('tasks') is not None:
for k in m.get('tasks'):
temp_model = DescribeWorkflowResponseBodyTasks()
self.tasks.append(temp_model.from_map(k))
return self
class DescribeWorkflowResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeWorkflowResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeWorkflowResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeWorkflowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DescribeWorkflowInstanceRequest(TeaModel):
def __init__(self, workspace_id=None):
self.workspace_id = workspace_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(DescribeWorkflowInstanceRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class DescribeWorkflowInstanceResponseBody(TeaModel):
def __init__(self, emr_cluster_id=None, end_date=None, is_complement_data=None, name=None, request_id=None,
resource_group_id=None, run_times=None, schedule_time=None, start_date=None, state=None, timeout=None,
workflow_id=None, workflow_version=None):
self.emr_cluster_id = emr_cluster_id # type: str
self.end_date = end_date # type: str
self.is_complement_data = is_complement_data # type: bool
self.name = name # type: str
self.request_id = request_id # type: str
self.resource_group_id = resource_group_id # type: str
self.run_times = run_times # type: int
self.schedule_time = schedule_time # type: str
self.start_date = start_date # type: str
self.state = state # type: str
self.timeout = timeout # type: int
self.workflow_id = workflow_id # type: long
self.workflow_version = workflow_version # type: int
def validate(self):
pass
def to_map(self):
_map = super(DescribeWorkflowInstanceResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
if self.emr_cluster_id is not None:
result['emrClusterId'] = self.emr_cluster_id
if self.end_date is not None:
result['endDate'] = self.end_date
if self.is_complement_data is not None:
result['isComplementData'] = self.is_complement_data
if self.name is not None:
result['name'] = self.name
if self.request_id is not None:
result['requestId'] = self.request_id
if self.resource_group_id is not None:
result['resourceGroupId'] = self.resource_group_id
if self.run_times is not None:
result['runTimes'] = self.run_times
if self.schedule_time is not None:
result['scheduleTime'] = self.schedule_time
if self.start_date is not None:
result['startDate'] = self.start_date
if self.state is not None:
result['state'] = self.state
if self.timeout is not None:
result['timeout'] = self.timeout
if self.workflow_id is not None:
result['workflowId'] = self.workflow_id
if self.workflow_version is not None:
result['workflowVersion'] = self.workflow_version
return result
def from_map(self, m=None):
m = m or dict()
if m.get('emrClusterId') is not None:
self.emr_cluster_id = m.get('emrClusterId')
if m.get('endDate') is not None:
self.end_date = m.get('endDate')
if m.get('isComplementData') is not None:
self.is_complement_data = m.get('isComplementData')
if m.get('name') is not None:
self.name = m.get('name')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
if m.get('resourceGroupId') is not None:
self.resource_group_id = m.get('resourceGroupId')
if m.get('runTimes') is not None:
self.run_times = m.get('runTimes')
if m.get('scheduleTime') is not None:
self.schedule_time = m.get('scheduleTime')
if m.get('startDate') is not None:
self.start_date = m.get('startDate')
if m.get('state') is not None:
self.state = m.get('state')
if m.get('timeout') is not None:
self.timeout = m.get('timeout')
if m.get('workflowId') is not None:
self.workflow_id = m.get('workflowId')
if m.get('workflowVersion') is not None:
self.workflow_version = m.get('workflowVersion')
return self
class DescribeWorkflowInstanceResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: DescribeWorkflowInstanceResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(DescribeWorkflowInstanceResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = DescribeWorkflowInstanceResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListManualTaskInstancesRequest(TeaModel):
def __init__(self, end_time=None, execution_status=None, max_results=None, next_token=None, search_val=None,
start_time=None, workspace_id=None):
self.end_time = end_time # type: str
self.execution_status = execution_status # type: str
self.max_results = max_results # type: int
self.next_token = next_token # type: str
self.search_val = search_val # type: str
self.start_time = start_time # type: str
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListManualTaskInstancesRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.end_time is not None:
result['endTime'] = self.end_time
if self.execution_status is not None:
result['executionStatus'] = self.execution_status
if self.max_results is not None:
result['maxResults'] = self.max_results
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.search_val is not None:
result['searchVal'] = self.search_val
if self.start_time is not None:
result['startTime'] = self.start_time
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('endTime') is not None:
self.end_time = m.get('endTime')
if m.get('executionStatus') is not None:
self.execution_status = m.get('executionStatus')
if m.get('maxResults') is not None:
self.max_results = m.get('maxResults')
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('searchVal') is not None:
self.search_val = m.get('searchVal')
if m.get('startTime') is not None:
self.start_time = m.get('startTime')
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class ListManualTaskInstancesResponseBodyData(TeaModel):
def __init__(self, emr_cluster_id=None, end_time=None, external_app_id=None, manual_task_instance_id=None,
manual_task_instance_name=None, resource_group_id=None, start_time=None, status=None, submit_time=None, task_params=None,
task_type=None):
# EMR集群ID
self.emr_cluster_id = emr_cluster_id # type: str
# 结束时间
self.end_time = end_time # type: str
# 外部应用ID
self.external_app_id = external_app_id # type: str
# 代表资源一级ID的资源属性字段
self.manual_task_instance_id = manual_task_instance_id # type: str
# 代表资源名称的资源属性字段
self.manual_task_instance_name = manual_task_instance_name # type: str
# 资源组ID
self.resource_group_id = resource_group_id # type: str
# 开始时间
self.start_time = start_time # type: str
# 状态
self.status = status # type: str
# 提交时间
self.submit_time = submit_time # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务类型
self.task_type = task_type # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListManualTaskInstancesResponseBodyData, self).to_map()
if _map is not None:
return _map
result = dict()
if self.emr_cluster_id is not None:
result['EmrClusterId'] = self.emr_cluster_id
if self.end_time is not None:
result['EndTime'] = self.end_time
if self.external_app_id is not None:
result['ExternalAppId'] = self.external_app_id
if self.manual_task_instance_id is not None:
result['ManualTaskInstanceId'] = self.manual_task_instance_id
if self.manual_task_instance_name is not None:
result['ManualTaskInstanceName'] = self.manual_task_instance_name
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.start_time is not None:
result['StartTime'] = self.start_time
if self.status is not None:
result['Status'] = self.status
if self.submit_time is not None:
result['SubmitTime'] = self.submit_time
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_type is not None:
result['TaskType'] = self.task_type
return result
def from_map(self, m=None):
m = m or dict()
if m.get('EmrClusterId') is not None:
self.emr_cluster_id = m.get('EmrClusterId')
if m.get('EndTime') is not None:
self.end_time = m.get('EndTime')
if m.get('ExternalAppId') is not None:
self.external_app_id = m.get('ExternalAppId')
if m.get('ManualTaskInstanceId') is not None:
self.manual_task_instance_id = m.get('ManualTaskInstanceId')
if m.get('ManualTaskInstanceName') is not None:
self.manual_task_instance_name = m.get('ManualTaskInstanceName')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('StartTime') is not None:
self.start_time = m.get('StartTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('SubmitTime') is not None:
self.submit_time = m.get('SubmitTime')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
return self
class ListManualTaskInstancesResponseBody(TeaModel):
def __init__(self, data=None, next_token=None, request_id=None, total_size=None):
self.data = data # type: list[ListManualTaskInstancesResponseBodyData]
self.next_token = next_token # type: str
# Id of the request
self.request_id = request_id # type: str
self.total_size = total_size # type: int
def validate(self):
if self.data:
for k in self.data:
if k:
k.validate()
def to_map(self):
_map = super(ListManualTaskInstancesResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
result['data'] = []
if self.data is not None:
for k in self.data:
result['data'].append(k.to_map() if k else None)
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.request_id is not None:
result['requestId'] = self.request_id
if self.total_size is not None:
result['totalSize'] = self.total_size
return result
def from_map(self, m=None):
m = m or dict()
self.data = []
if m.get('data') is not None:
for k in m.get('data'):
temp_model = ListManualTaskInstancesResponseBodyData()
self.data.append(temp_model.from_map(k))
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
if m.get('totalSize') is not None:
self.total_size = m.get('totalSize')
return self
class ListManualTaskInstancesResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListManualTaskInstancesResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListManualTaskInstancesResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListManualTaskInstancesResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListManualTasksRequest(TeaModel):
def __init__(self, max_results=None, next_token=None, search_val=None, task_type=None, workspace_id=None):
self.max_results = max_results # type: int
self.next_token = next_token # type: str
self.search_val = search_val # type: str
self.task_type = task_type # type: str
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListManualTasksRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.max_results is not None:
result['maxResults'] = self.max_results
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.search_val is not None:
result['searchVal'] = self.search_val
if self.task_type is not None:
result['taskType'] = self.task_type
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('maxResults') is not None:
self.max_results = m.get('maxResults')
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('searchVal') is not None:
self.search_val = m.get('searchVal')
if m.get('taskType') is not None:
self.task_type = m.get('taskType')
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class ListManualTasksResponseBodyData(TeaModel):
def __init__(self, create_time=None, description=None, manual_task_id=None, manual_task_name=None,
parent_directory_id=None, project_id=None, resource_ids=None, task_params=None, task_type=None, update_time=None):
# 代表创建时间的资源属性字段
self.create_time = create_time # type: str
# 描述
self.description = description # type: str
# 代表资源一级ID的资源属性字段
self.manual_task_id = manual_task_id # type: str
# 代表资源名称的资源属性字段
self.manual_task_name = manual_task_name # type: str
# 目录ID
self.parent_directory_id = parent_directory_id # type: str
# 项目ID
self.project_id = project_id # type: str
# 资源id列表
self.resource_ids = resource_ids # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务类型
self.task_type = task_type # type: str
# 更新时间
self.update_time = update_time # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListManualTasksResponseBodyData, self).to_map()
if _map is not None:
return _map
result = dict()
if self.create_time is not None:
result['CreateTime'] = self.create_time
if self.description is not None:
result['Description'] = self.description
if self.manual_task_id is not None:
result['ManualTaskId'] = self.manual_task_id
if self.manual_task_name is not None:
result['ManualTaskName'] = self.manual_task_name
if self.parent_directory_id is not None:
result['ParentDirectoryId'] = self.parent_directory_id
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.resource_ids is not None:
result['ResourceIds'] = self.resource_ids
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_type is not None:
result['TaskType'] = self.task_type
if self.update_time is not None:
result['UpdateTime'] = self.update_time
return result
def from_map(self, m=None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('ManualTaskId') is not None:
self.manual_task_id = m.get('ManualTaskId')
if m.get('ManualTaskName') is not None:
self.manual_task_name = m.get('ManualTaskName')
if m.get('ParentDirectoryId') is not None:
self.parent_directory_id = m.get('ParentDirectoryId')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('ResourceIds') is not None:
self.resource_ids = m.get('ResourceIds')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
return self
class ListManualTasksResponseBody(TeaModel):
def __init__(self, data=None, next_token=None, request_id=None, total_size=None):
self.data = data # type: list[ListManualTasksResponseBodyData]
self.next_token = next_token # type: str
# Id of the request
self.request_id = request_id # type: str
self.total_size = total_size # type: int
def validate(self):
if self.data:
for k in self.data:
if k:
k.validate()
def to_map(self):
_map = super(ListManualTasksResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
result['data'] = []
if self.data is not None:
for k in self.data:
result['data'].append(k.to_map() if k else None)
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.request_id is not None:
result['requestId'] = self.request_id
if self.total_size is not None:
result['totalSize'] = self.total_size
return result
def from_map(self, m=None):
m = m or dict()
self.data = []
if m.get('data') is not None:
for k in m.get('data'):
temp_model = ListManualTasksResponseBodyData()
self.data.append(temp_model.from_map(k))
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
if m.get('totalSize') is not None:
self.total_size = m.get('totalSize')
return self
class ListManualTasksResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListManualTasksResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListManualTasksResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListManualTasksResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListProjectsRequest(TeaModel):
def __init__(self, max_results=None, next_token=None, search_val=None, workspace_id=None):
self.max_results = max_results # type: int
self.next_token = next_token # type: str
self.search_val = search_val # type: str
self.workspace_id = workspace_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(ListProjectsRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.max_results is not None:
result['maxResults'] = self.max_results
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.search_val is not None:
result['searchVal'] = self.search_val
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('maxResults') is not None:
self.max_results = m.get('maxResults')
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('searchVal') is not None:
self.search_val = m.get('searchVal')
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class ListProjectsResponseBodyData(TeaModel):
def __init__(self, code=None, description=None, name=None, project_id=None):
self.code = code # type: long
self.description = description # type: str
self.name = name # type: str
self.project_id = project_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(ListProjectsResponseBodyData, self).to_map()
if _map is not None:
return _map
result = dict()
if self.code is not None:
result['code'] = self.code
if self.description is not None:
result['description'] = self.description
if self.name is not None:
result['name'] = self.name
if self.project_id is not None:
result['projectId'] = self.project_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('code') is not None:
self.code = m.get('code')
if m.get('description') is not None:
self.description = m.get('description')
if m.get('name') is not None:
self.name = m.get('name')
if m.get('projectId') is not None:
self.project_id = m.get('projectId')
return self
class ListProjectsResponseBody(TeaModel):
def __init__(self, data=None, next_token=None, request_id=None):
self.data = data # type: list[ListProjectsResponseBodyData]
self.next_token = next_token # type: str
self.request_id = request_id # type: str
def validate(self):
if self.data:
for k in self.data:
if k:
k.validate()
def to_map(self):
_map = super(ListProjectsResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
result['data'] = []
if self.data is not None:
for k in self.data:
result['data'].append(k.to_map() if k else None)
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.request_id is not None:
result['requestId'] = self.request_id
return result
def from_map(self, m=None):
m = m or dict()
self.data = []
if m.get('data') is not None:
for k in m.get('data'):
temp_model = ListProjectsResponseBodyData()
self.data.append(temp_model.from_map(k))
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
return self
class ListProjectsResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListProjectsResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListProjectsResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListProjectsResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListTaskInstancesRequest(TeaModel):
def __init__(self, end_time=None, execution_status=None, max_results=None, next_token=None, search_val=None,
start_time=None, workflow_instance_id=None, workspace_id=None):
self.end_time = end_time # type: str
self.execution_status = execution_status # type: str
self.max_results = max_results # type: int
self.next_token = next_token # type: str
self.search_val = search_val # type: str
self.start_time = start_time # type: str
self.workflow_instance_id = workflow_instance_id # type: str
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListTaskInstancesRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.end_time is not None:
result['endTime'] = self.end_time
if self.execution_status is not None:
result['executionStatus'] = self.execution_status
if self.max_results is not None:
result['maxResults'] = self.max_results
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.search_val is not None:
result['searchVal'] = self.search_val
if self.start_time is not None:
result['startTime'] = self.start_time
if self.workflow_instance_id is not None:
result['workflowInstanceId'] = self.workflow_instance_id
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('endTime') is not None:
self.end_time = m.get('endTime')
if m.get('executionStatus') is not None:
self.execution_status = m.get('executionStatus')
if m.get('maxResults') is not None:
self.max_results = m.get('maxResults')
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('searchVal') is not None:
self.search_val = m.get('searchVal')
if m.get('startTime') is not None:
self.start_time = m.get('startTime')
if m.get('workflowInstanceId') is not None:
self.workflow_instance_id = m.get('workflowInstanceId')
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class ListTaskInstancesResponseBodyData(TeaModel):
def __init__(self, dry_run=None, emr_cluster_id=None, end_time=None, external_app_id=None,
resource_group_id=None, retry_times=None, start_time=None, status=None, submit_time=None, task_id=None,
task_instance_id=None, task_instance_name=None, task_params=None, task_type=None, task_version=None,
workflow_instance_id=None):
# 空跑标识
self.dry_run = dry_run # type: str
# EMR集群ID
self.emr_cluster_id = emr_cluster_id # type: str
# 结束时间
self.end_time = end_time # type: str
# 外部应用ID
self.external_app_id = external_app_id # type: str
# 资源组ID
self.resource_group_id = resource_group_id # type: str
# 重试次数
self.retry_times = retry_times # type: int
# 开始时间
self.start_time = start_time # type: str
# 状态
self.status = status # type: str
# 提交时间
self.submit_time = submit_time # type: str
# 任务ID
self.task_id = task_id # type: str
# 任务实例ID
self.task_instance_id = task_instance_id # type: str
# 任务实例名称
self.task_instance_name = task_instance_name # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务类型
self.task_type = task_type # type: str
# 任务版本
self.task_version = task_version # type: str
# 工作流实例ID
self.workflow_instance_id = workflow_instance_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListTaskInstancesResponseBodyData, self).to_map()
if _map is not None:
return _map
result = dict()
if self.dry_run is not None:
result['DryRun'] = self.dry_run
if self.emr_cluster_id is not None:
result['EmrClusterId'] = self.emr_cluster_id
if self.end_time is not None:
result['EndTime'] = self.end_time
if self.external_app_id is not None:
result['ExternalAppId'] = self.external_app_id
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.retry_times is not None:
result['RetryTimes'] = self.retry_times
if self.start_time is not None:
result['StartTime'] = self.start_time
if self.status is not None:
result['Status'] = self.status
if self.submit_time is not None:
result['SubmitTime'] = self.submit_time
if self.task_id is not None:
result['TaskId'] = self.task_id
if self.task_instance_id is not None:
result['TaskInstanceId'] = self.task_instance_id
if self.task_instance_name is not None:
result['TaskInstanceName'] = self.task_instance_name
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_type is not None:
result['TaskType'] = self.task_type
if self.task_version is not None:
result['TaskVersion'] = self.task_version
if self.workflow_instance_id is not None:
result['WorkflowInstanceId'] = self.workflow_instance_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('DryRun') is not None:
self.dry_run = m.get('DryRun')
if m.get('EmrClusterId') is not None:
self.emr_cluster_id = m.get('EmrClusterId')
if m.get('EndTime') is not None:
self.end_time = m.get('EndTime')
if m.get('ExternalAppId') is not None:
self.external_app_id = m.get('ExternalAppId')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('RetryTimes') is not None:
self.retry_times = m.get('RetryTimes')
if m.get('StartTime') is not None:
self.start_time = m.get('StartTime')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('SubmitTime') is not None:
self.submit_time = m.get('SubmitTime')
if m.get('TaskId') is not None:
self.task_id = m.get('TaskId')
if m.get('TaskInstanceId') is not None:
self.task_instance_id = m.get('TaskInstanceId')
if m.get('TaskInstanceName') is not None:
self.task_instance_name = m.get('TaskInstanceName')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
if m.get('TaskVersion') is not None:
self.task_version = m.get('TaskVersion')
if m.get('WorkflowInstanceId') is not None:
self.workflow_instance_id = m.get('WorkflowInstanceId')
return self
class ListTaskInstancesResponseBody(TeaModel):
def __init__(self, data=None, next_token=None, request_id=None, total_size=None):
self.data = data # type: list[ListTaskInstancesResponseBodyData]
self.next_token = next_token # type: str
# Id of the request
self.request_id = request_id # type: str
self.total_size = total_size # type: int
def validate(self):
if self.data:
for k in self.data:
if k:
k.validate()
def to_map(self):
_map = super(ListTaskInstancesResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
result['data'] = []
if self.data is not None:
for k in self.data:
result['data'].append(k.to_map() if k else None)
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.request_id is not None:
result['requestId'] = self.request_id
if self.total_size is not None:
result['totalSize'] = self.total_size
return result
def from_map(self, m=None):
m = m or dict()
self.data = []
if m.get('data') is not None:
for k in m.get('data'):
temp_model = ListTaskInstancesResponseBodyData()
self.data.append(temp_model.from_map(k))
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
if m.get('totalSize') is not None:
self.total_size = m.get('totalSize')
return self
class ListTaskInstancesResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListTaskInstancesResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListTaskInstancesResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListTaskInstancesResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListTasksRequest(TeaModel):
def __init__(self, max_results=None, next_token=None, search_val=None, task_type=None, workflow_id=None,
workspace_id=None):
self.max_results = max_results # type: str
self.next_token = next_token # type: str
self.search_val = search_val # type: str
self.task_type = task_type # type: str
self.workflow_id = workflow_id # type: str
self.workspace_id = workspace_id # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListTasksRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.max_results is not None:
result['maxResults'] = self.max_results
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.search_val is not None:
result['searchVal'] = self.search_val
if self.task_type is not None:
result['taskType'] = self.task_type
if self.workflow_id is not None:
result['workflowId'] = self.workflow_id
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('maxResults') is not None:
self.max_results = m.get('maxResults')
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('searchVal') is not None:
self.search_val = m.get('searchVal')
if m.get('taskType') is not None:
self.task_type = m.get('taskType')
if m.get('workflowId') is not None:
self.workflow_id = m.get('workflowId')
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class ListTasksResponseBodyData(TeaModel):
def __init__(self, create_time=None, delay_time=None, description=None, fail_retry_interval=None,
fail_retry_times=None, flag=None, project_id=None, resource_ids=None, task_id=None, task_name=None, task_params=None,
task_priority=None, task_type=None, timeout=None, timeout_flag=None, timeout_notify_strategy=None,
update_time=None, version=None):
# 代表创建时间的资源属性字段
self.create_time = create_time # type: str
# 延时执行时间
self.delay_time = delay_time # type: int
# 描述
self.description = description # type: str
# 失败重试间隔
self.fail_retry_interval = fail_retry_interval # type: int
# 失败重试次数
self.fail_retry_times = fail_retry_times # type: int
# 运行标志
self.flag = flag # type: str
# 项目ID
self.project_id = project_id # type: str
# 资源ID列表
self.resource_ids = resource_ids # type: str
# 代表资源一级ID的资源属性字段
self.task_id = task_id # type: str
# 代表资源名称的资源属性字段
self.task_name = task_name # type: str
# 任务参数
self.task_params = task_params # type: str
# 任务优先级
self.task_priority = task_priority # type: str
# 任务类型
self.task_type = task_type # type: str
# 超时时长
self.timeout = timeout # type: int
# 超时告警标志
self.timeout_flag = timeout_flag # type: str
# 超时告警标志
self.timeout_notify_strategy = timeout_notify_strategy # type: str
# 更新时间
self.update_time = update_time # type: str
# 版本
self.version = version # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListTasksResponseBodyData, self).to_map()
if _map is not None:
return _map
result = dict()
if self.create_time is not None:
result['CreateTime'] = self.create_time
if self.delay_time is not None:
result['DelayTime'] = self.delay_time
if self.description is not None:
result['Description'] = self.description
if self.fail_retry_interval is not None:
result['FailRetryInterval'] = self.fail_retry_interval
if self.fail_retry_times is not None:
result['FailRetryTimes'] = self.fail_retry_times
if self.flag is not None:
result['Flag'] = self.flag
if self.project_id is not None:
result['ProjectId'] = self.project_id
if self.resource_ids is not None:
result['ResourceIds'] = self.resource_ids
if self.task_id is not None:
result['TaskId'] = self.task_id
if self.task_name is not None:
result['TaskName'] = self.task_name
if self.task_params is not None:
result['TaskParams'] = self.task_params
if self.task_priority is not None:
result['TaskPriority'] = self.task_priority
if self.task_type is not None:
result['TaskType'] = self.task_type
if self.timeout is not None:
result['Timeout'] = self.timeout
if self.timeout_flag is not None:
result['TimeoutFlag'] = self.timeout_flag
if self.timeout_notify_strategy is not None:
result['TimeoutNotifyStrategy'] = self.timeout_notify_strategy
if self.update_time is not None:
result['UpdateTime'] = self.update_time
if self.version is not None:
result['Version'] = self.version
return result
def from_map(self, m=None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('DelayTime') is not None:
self.delay_time = m.get('DelayTime')
if m.get('Description') is not None:
self.description = m.get('Description')
if m.get('FailRetryInterval') is not None:
self.fail_retry_interval = m.get('FailRetryInterval')
if m.get('FailRetryTimes') is not None:
self.fail_retry_times = m.get('FailRetryTimes')
if m.get('Flag') is not None:
self.flag = m.get('Flag')
if m.get('ProjectId') is not None:
self.project_id = m.get('ProjectId')
if m.get('ResourceIds') is not None:
self.resource_ids = m.get('ResourceIds')
if m.get('TaskId') is not None:
self.task_id = m.get('TaskId')
if m.get('TaskName') is not None:
self.task_name = m.get('TaskName')
if m.get('TaskParams') is not None:
self.task_params = m.get('TaskParams')
if m.get('TaskPriority') is not None:
self.task_priority = m.get('TaskPriority')
if m.get('TaskType') is not None:
self.task_type = m.get('TaskType')
if m.get('Timeout') is not None:
self.timeout = m.get('Timeout')
if m.get('TimeoutFlag') is not None:
self.timeout_flag = m.get('TimeoutFlag')
if m.get('TimeoutNotifyStrategy') is not None:
self.timeout_notify_strategy = m.get('TimeoutNotifyStrategy')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
if m.get('Version') is not None:
self.version = m.get('Version')
return self
class ListTasksResponseBody(TeaModel):
def __init__(self, data=None, next_token=None, request_id=None, total_size=None):
self.data = data # type: list[ListTasksResponseBodyData]
self.next_token = next_token # type: str
# Id of the request
self.request_id = request_id # type: str
self.total_size = total_size # type: int
def validate(self):
if self.data:
for k in self.data:
if k:
k.validate()
def to_map(self):
_map = super(ListTasksResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
result['data'] = []
if self.data is not None:
for k in self.data:
result['data'].append(k.to_map() if k else None)
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.request_id is not None:
result['requestId'] = self.request_id
if self.total_size is not None:
result['totalSize'] = self.total_size
return result
def from_map(self, m=None):
m = m or dict()
self.data = []
if m.get('data') is not None:
for k in m.get('data'):
temp_model = ListTasksResponseBodyData()
self.data.append(temp_model.from_map(k))
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
if m.get('totalSize') is not None:
self.total_size = m.get('totalSize')
return self
class ListTasksResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListTasksResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListTasksResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListTasksResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListWorkflowInstancesRequest(TeaModel):
def __init__(self, end_date=None, max_results=None, next_token=None, start_date=None, workflow_id=None,
workspace_id=None):
self.end_date = end_date # type: str
self.max_results = max_results # type: int
self.next_token = next_token # type: str
self.start_date = start_date # type: str
self.workflow_id = workflow_id # type: long
self.workspace_id = workspace_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(ListWorkflowInstancesRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.end_date is not None:
result['endDate'] = self.end_date
if self.max_results is not None:
result['maxResults'] = self.max_results
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.start_date is not None:
result['startDate'] = self.start_date
if self.workflow_id is not None:
result['workflowId'] = self.workflow_id
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('endDate') is not None:
self.end_date = m.get('endDate')
if m.get('maxResults') is not None:
self.max_results = m.get('maxResults')
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('startDate') is not None:
self.start_date = m.get('startDate')
if m.get('workflowId') is not None:
self.workflow_id = m.get('workflowId')
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class ListWorkflowInstancesResponseBodyData(TeaModel):
def __init__(self, end_date=None, name=None, run_times=None, schedule_time=None, start_date=None, state=None,
workflow_id=None, workflow_instance_id=None, workflow_version=None):
self.end_date = end_date # type: str
self.name = name # type: str
self.run_times = run_times # type: str
self.schedule_time = schedule_time # type: str
self.start_date = start_date # type: str
self.state = state # type: str
self.workflow_id = workflow_id # type: long
self.workflow_instance_id = workflow_instance_id # type: long
self.workflow_version = workflow_version # type: str
def validate(self):
pass
def to_map(self):
_map = super(ListWorkflowInstancesResponseBodyData, self).to_map()
if _map is not None:
return _map
result = dict()
if self.end_date is not None:
result['endDate'] = self.end_date
if self.name is not None:
result['name'] = self.name
if self.run_times is not None:
result['runTimes'] = self.run_times
if self.schedule_time is not None:
result['scheduleTime'] = self.schedule_time
if self.start_date is not None:
result['startDate'] = self.start_date
if self.state is not None:
result['state'] = self.state
if self.workflow_id is not None:
result['workflowId'] = self.workflow_id
if self.workflow_instance_id is not None:
result['workflowInstanceId'] = self.workflow_instance_id
if self.workflow_version is not None:
result['workflowVersion'] = self.workflow_version
return result
def from_map(self, m=None):
m = m or dict()
if m.get('endDate') is not None:
self.end_date = m.get('endDate')
if m.get('name') is not None:
self.name = m.get('name')
if m.get('runTimes') is not None:
self.run_times = m.get('runTimes')
if m.get('scheduleTime') is not None:
self.schedule_time = m.get('scheduleTime')
if m.get('startDate') is not None:
self.start_date = m.get('startDate')
if m.get('state') is not None:
self.state = m.get('state')
if m.get('workflowId') is not None:
self.workflow_id = m.get('workflowId')
if m.get('workflowInstanceId') is not None:
self.workflow_instance_id = m.get('workflowInstanceId')
if m.get('workflowVersion') is not None:
self.workflow_version = m.get('workflowVersion')
return self
class ListWorkflowInstancesResponseBody(TeaModel):
def __init__(self, data=None, next_token=None, request_id=None, total_size=None):
self.data = data # type: list[ListWorkflowInstancesResponseBodyData]
self.next_token = next_token # type: str
self.request_id = request_id # type: str
self.total_size = total_size # type: int
def validate(self):
if self.data:
for k in self.data:
if k:
k.validate()
def to_map(self):
_map = super(ListWorkflowInstancesResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
result['data'] = []
if self.data is not None:
for k in self.data:
result['data'].append(k.to_map() if k else None)
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.request_id is not None:
result['requestId'] = self.request_id
if self.total_size is not None:
result['totalSize'] = self.total_size
return result
def from_map(self, m=None):
m = m or dict()
self.data = []
if m.get('data') is not None:
for k in m.get('data'):
temp_model = ListWorkflowInstancesResponseBodyData()
self.data.append(temp_model.from_map(k))
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
if m.get('totalSize') is not None:
self.total_size = m.get('totalSize')
return self
class ListWorkflowInstancesResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListWorkflowInstancesResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListWorkflowInstancesResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListWorkflowInstancesResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListWorkflowsRequest(TeaModel):
def __init__(self, max_results=None, next_token=None, search_val=None, workspace_id=None):
self.max_results = max_results # type: int
self.next_token = next_token # type: str
self.search_val = search_val # type: str
self.workspace_id = workspace_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(ListWorkflowsRequest, self).to_map()
if _map is not None:
return _map
result = dict()
if self.max_results is not None:
result['maxResults'] = self.max_results
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.search_val is not None:
result['searchVal'] = self.search_val
if self.workspace_id is not None:
result['workspaceId'] = self.workspace_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('maxResults') is not None:
self.max_results = m.get('maxResults')
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('searchVal') is not None:
self.search_val = m.get('searchVal')
if m.get('workspaceId') is not None:
self.workspace_id = m.get('workspaceId')
return self
class ListWorkflowsResponseBodyData(TeaModel):
def __init__(self, create_time=None, description=None, name=None, release_state=None, update_time=None,
workflow_id=None):
self.create_time = create_time # type: str
self.description = description # type: str
self.name = name # type: str
self.release_state = release_state # type: str
self.update_time = update_time # type: str
self.workflow_id = workflow_id # type: long
def validate(self):
pass
def to_map(self):
_map = super(ListWorkflowsResponseBodyData, self).to_map()
if _map is not None:
return _map
result = dict()
if self.create_time is not None:
result['createTime'] = self.create_time
if self.description is not None:
result['description'] = self.description
if self.name is not None:
result['name'] = self.name
if self.release_state is not None:
result['releaseState'] = self.release_state
if self.update_time is not None:
result['updateTime'] = self.update_time
if self.workflow_id is not None:
result['workflowId'] = self.workflow_id
return result
def from_map(self, m=None):
m = m or dict()
if m.get('createTime') is not None:
self.create_time = m.get('createTime')
if m.get('description') is not None:
self.description = m.get('description')
if m.get('name') is not None:
self.name = m.get('name')
if m.get('releaseState') is not None:
self.release_state = m.get('releaseState')
if m.get('updateTime') is not None:
self.update_time = m.get('updateTime')
if m.get('workflowId') is not None:
self.workflow_id = m.get('workflowId')
return self
class ListWorkflowsResponseBody(TeaModel):
def __init__(self, data=None, next_token=None, request_id=None, total_size=None):
self.data = data # type: list[ListWorkflowsResponseBodyData]
self.next_token = next_token # type: str
self.request_id = request_id # type: str
self.total_size = total_size # type: int
def validate(self):
if self.data:
for k in self.data:
if k:
k.validate()
def to_map(self):
_map = super(ListWorkflowsResponseBody, self).to_map()
if _map is not None:
return _map
result = dict()
result['data'] = []
if self.data is not None:
for k in self.data:
result['data'].append(k.to_map() if k else None)
if self.next_token is not None:
result['nextToken'] = self.next_token
if self.request_id is not None:
result['requestId'] = self.request_id
if self.total_size is not None:
result['totalSize'] = self.total_size
return result
def from_map(self, m=None):
m = m or dict()
self.data = []
if m.get('data') is not None:
for k in m.get('data'):
temp_model = ListWorkflowsResponseBodyData()
self.data.append(temp_model.from_map(k))
if m.get('nextToken') is not None:
self.next_token = m.get('nextToken')
if m.get('requestId') is not None:
self.request_id = m.get('requestId')
if m.get('totalSize') is not None:
self.total_size = m.get('totalSize')
return self
class ListWorkflowsResponse(TeaModel):
def __init__(self, headers=None, status_code=None, body=None):
self.headers = headers # type: dict[str, str]
self.status_code = status_code # type: int
self.body = body # type: ListWorkflowsResponseBody
def validate(self):
if self.body:
self.body.validate()
def to_map(self):
_map = super(ListWorkflowsResponse, self).to_map()
if _map is not None:
return _map
result = dict()
if self.headers is not None:
result['headers'] = self.headers
if self.status_code is not None:
result['statusCode'] = self.status_code
if self.body is not None:
result['body'] = self.body.to_map()
return result
def from_map(self, m=None):
m = m or dict()
if m.get('headers') is not None:
self.headers = m.get('headers')
if m.get('statusCode') is not None:
self.status_code = m.get('statusCode')
if m.get('body') is not None:
temp_model = ListWorkflowsResponseBody()
self.body = temp_model.from_map(m['body'])
return self