composer-20181212/alibabacloud_composer20181212/models.py (2,340 lines of code) (raw):
# -*- coding: utf-8 -*-
# This file is auto-generated, don't edit it. Thanks.
from Tea.model import TeaModel
from typing import Dict, List
class CloneFlowRequest(TeaModel):
def __init__(
self,
flow_id: str = None,
version_id: str = None,
):
# The ID of the workflow that you want to clone.
self.flow_id = flow_id
# The version of the workflow that you want to clone. If you do not specify this parameter, the latest version of the workflow is cloned.
self.version_id = version_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.version_id is not None:
result['VersionId'] = self.version_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('VersionId') is not None:
self.version_id = m.get('VersionId')
return self
class CloneFlowResponseBody(TeaModel):
def __init__(
self,
flow_id: str = None,
request_id: str = None,
):
# The ID of the cloned workflow.
self.flow_id = flow_id
# The ID of the request.
self.request_id = request_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CloneFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: CloneFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = CloneFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class CreateFlowRequest(TeaModel):
def __init__(
self,
definition: str = None,
flow_description: str = None,
flow_name: str = None,
flow_source: str = None,
resource_group_id: str = None,
template_id: str = None,
):
# The definition of the workflow, which must be a JSON string.
self.definition = definition
# The description of the workflow.
self.flow_description = flow_description
# The name of the workflow.
self.flow_name = flow_name
# The source of the workflow. Valid values:
#
# * Default: Create the workflow in the console.
# * CloudConfig: Create the workflow by using Cloud Config.
# * Solution: Create the workflow by using Logic Composer.
self.flow_source = flow_source
# The ID of the resource group.
self.resource_group_id = resource_group_id
# The ID of the template.
self.template_id = template_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.definition is not None:
result['Definition'] = self.definition
if self.flow_description is not None:
result['FlowDescription'] = self.flow_description
if self.flow_name is not None:
result['FlowName'] = self.flow_name
if self.flow_source is not None:
result['FlowSource'] = self.flow_source
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.template_id is not None:
result['TemplateId'] = self.template_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('Definition') is not None:
self.definition = m.get('Definition')
if m.get('FlowDescription') is not None:
self.flow_description = m.get('FlowDescription')
if m.get('FlowName') is not None:
self.flow_name = m.get('FlowName')
if m.get('FlowSource') is not None:
self.flow_source = m.get('FlowSource')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('TemplateId') is not None:
self.template_id = m.get('TemplateId')
return self
class CreateFlowResponseBody(TeaModel):
def __init__(
self,
flow_id: str = None,
request_id: str = None,
):
# The ID of the created workflow.
self.flow_id = flow_id
# The ID of the request.
self.request_id = request_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.request_id is not None:
result['RequestId'] = self.request_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
return self
class CreateFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: CreateFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = CreateFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DeleteFlowRequest(TeaModel):
def __init__(
self,
flow_id: str = None,
):
# The ID of the workflow that you want to delete.
self.flow_id = flow_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
return self
class DeleteFlowResponseBody(TeaModel):
def __init__(
self,
request_id: str = None,
success: bool = None,
):
# The ID of the request.
self.request_id = request_id
# Indicates whether the operation was successful. Valid values: **true**: The operation was successful. **false**: The operation failed.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class DeleteFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: DeleteFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = DeleteFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class DisableFlowRequest(TeaModel):
def __init__(
self,
flow_id: str = None,
):
# The ID of the workflow that you want to disable.
self.flow_id = flow_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
return self
class DisableFlowResponseBody(TeaModel):
def __init__(
self,
flow_status: str = None,
request_id: str = None,
success: bool = None,
):
# The status of the workflow.
#
# * **Enabled**: The workflow is enabled.
# * **Disabled**: The workflow is disabled.
self.flow_status = flow_status
# The ID of the request.
self.request_id = request_id
# Indicates whether the operation was successful.
#
# * **true**: The operation was successful.
# * **false**: The operation failed.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_status is not None:
result['FlowStatus'] = self.flow_status
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowStatus') is not None:
self.flow_status = m.get('FlowStatus')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class DisableFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: DisableFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = DisableFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class EnableFlowRequest(TeaModel):
def __init__(
self,
flow_id: str = None,
):
# The ID of the workflow that you want to enable.
self.flow_id = flow_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
return self
class EnableFlowResponseBody(TeaModel):
def __init__(
self,
flow_status: str = None,
request_id: str = None,
success: bool = None,
):
# The status of the workflow. Valid values:
#
# * **Enabled**: The workflow is enabled.
# * **Disabled**: The workflow is disabled.
self.flow_status = flow_status
# The ID of the request.
self.request_id = request_id
# Indicates whether the operation was successful. Valid values:
#
# * **true**: The operation was successful.
# * **false**: The operation failed.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_status is not None:
result['FlowStatus'] = self.flow_status
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowStatus') is not None:
self.flow_status = m.get('FlowStatus')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class EnableFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: EnableFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = EnableFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class GetFlowRequest(TeaModel):
def __init__(
self,
flow_id: str = None,
):
# The ID of the workflow.
self.flow_id = flow_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
return self
class GetFlowResponseBody(TeaModel):
def __init__(
self,
create_time: str = None,
current_version_id: str = None,
definition: str = None,
flow_description: str = None,
flow_edit_mode: str = None,
flow_id: str = None,
flow_name: str = None,
flow_source: str = None,
flow_status: str = None,
region_id: str = None,
request_id: str = None,
resource_group_id: str = None,
template_id: str = None,
update_time: str = None,
):
# The time when the workflow was created.
self.create_time = create_time
# The version ID of the workflow.
self.current_version_id = current_version_id
# The definition of the workflow.
self.definition = definition
# The description of the workflow.
self.flow_description = flow_description
# The edit mode of the workflow.
self.flow_edit_mode = flow_edit_mode
# The ID of the workflow.
self.flow_id = flow_id
# The name of the workflow.
self.flow_name = flow_name
# The source of the workflow.
self.flow_source = flow_source
# The status of the workflow. Valid values:
#
# * **Enabled**: The workflow is enabled.
# * **Disabled**: The workflow is disabled.
self.flow_status = flow_status
# The ID of the region where the workflow resides.
self.region_id = region_id
# The ID of the request.
self.request_id = request_id
# The resource group ID.
self.resource_group_id = resource_group_id
# The template ID.
self.template_id = template_id
# The time when the workflow was last updated.
self.update_time = update_time
def validate(self):
pass
def to_map(self):
_map = super().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.current_version_id is not None:
result['CurrentVersionId'] = self.current_version_id
if self.definition is not None:
result['Definition'] = self.definition
if self.flow_description is not None:
result['FlowDescription'] = self.flow_description
if self.flow_edit_mode is not None:
result['FlowEditMode'] = self.flow_edit_mode
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.flow_name is not None:
result['FlowName'] = self.flow_name
if self.flow_source is not None:
result['FlowSource'] = self.flow_source
if self.flow_status is not None:
result['FlowStatus'] = self.flow_status
if self.region_id is not None:
result['RegionId'] = self.region_id
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.template_id is not None:
result['TemplateId'] = self.template_id
if self.update_time is not None:
result['UpdateTime'] = self.update_time
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('CurrentVersionId') is not None:
self.current_version_id = m.get('CurrentVersionId')
if m.get('Definition') is not None:
self.definition = m.get('Definition')
if m.get('FlowDescription') is not None:
self.flow_description = m.get('FlowDescription')
if m.get('FlowEditMode') is not None:
self.flow_edit_mode = m.get('FlowEditMode')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('FlowName') is not None:
self.flow_name = m.get('FlowName')
if m.get('FlowSource') is not None:
self.flow_source = m.get('FlowSource')
if m.get('FlowStatus') is not None:
self.flow_status = m.get('FlowStatus')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
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('TemplateId') is not None:
self.template_id = m.get('TemplateId')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
return self
class GetFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: GetFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = GetFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class GetTemplateRequest(TeaModel):
def __init__(
self,
template_id: str = None,
):
# The ID of the template.
self.template_id = template_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.template_id is not None:
result['TemplateId'] = self.template_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('TemplateId') is not None:
self.template_id = m.get('TemplateId')
return self
class GetTemplateResponseBody(TeaModel):
def __init__(
self,
create_time: str = None,
definition: str = None,
region_id: str = None,
request_id: str = None,
template_connector: str = None,
template_creator: str = None,
template_description: str = None,
template_id: str = None,
template_locale: str = None,
template_name: str = None,
template_overview: str = None,
template_summary: str = None,
template_summary_en: str = None,
template_tag: str = None,
template_version: int = None,
update_time: str = None,
):
# The time when the template was created.
self.create_time = create_time
# The definition of the template.
self.definition = definition
# The region where the template resides.
self.region_id = region_id
# The ID of the request.
self.request_id = request_id
# A list of connectors that are used in the template. The connectors are separated by commas.
self.template_connector = template_connector
# The publisher of the template.
self.template_creator = template_creator
# A description of the template.
self.template_description = template_description
# The ID of the template.
self.template_id = template_id
# The language that is used in the template. Chinese and English are supported.
self.template_locale = template_locale
# The name of the template.
self.template_name = template_name
# An overview of the template, which is a JSON string.
self.template_overview = template_overview
# A brief introduction to the template.
self.template_summary = template_summary
# A brief introduction to the template.
self.template_summary_en = template_summary_en
# The tag of the template.
self.template_tag = template_tag
# The version of the template, which is a number that increments from 0.
self.template_version = template_version
# The time when the template was last updated.
self.update_time = update_time
def validate(self):
pass
def to_map(self):
_map = super().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.definition is not None:
result['Definition'] = self.definition
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.template_connector is not None:
result['TemplateConnector'] = self.template_connector
if self.template_creator is not None:
result['TemplateCreator'] = self.template_creator
if self.template_description is not None:
result['TemplateDescription'] = self.template_description
if self.template_id is not None:
result['TemplateId'] = self.template_id
if self.template_locale is not None:
result['TemplateLocale'] = self.template_locale
if self.template_name is not None:
result['TemplateName'] = self.template_name
if self.template_overview is not None:
result['TemplateOverview'] = self.template_overview
if self.template_summary is not None:
result['TemplateSummary'] = self.template_summary
if self.template_summary_en is not None:
result['TemplateSummaryEn'] = self.template_summary_en
if self.template_tag is not None:
result['TemplateTag'] = self.template_tag
if self.template_version is not None:
result['TemplateVersion'] = self.template_version
if self.update_time is not None:
result['UpdateTime'] = self.update_time
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('Definition') is not None:
self.definition = m.get('Definition')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('TemplateConnector') is not None:
self.template_connector = m.get('TemplateConnector')
if m.get('TemplateCreator') is not None:
self.template_creator = m.get('TemplateCreator')
if m.get('TemplateDescription') is not None:
self.template_description = m.get('TemplateDescription')
if m.get('TemplateId') is not None:
self.template_id = m.get('TemplateId')
if m.get('TemplateLocale') is not None:
self.template_locale = m.get('TemplateLocale')
if m.get('TemplateName') is not None:
self.template_name = m.get('TemplateName')
if m.get('TemplateOverview') is not None:
self.template_overview = m.get('TemplateOverview')
if m.get('TemplateSummary') is not None:
self.template_summary = m.get('TemplateSummary')
if m.get('TemplateSummaryEn') is not None:
self.template_summary_en = m.get('TemplateSummaryEn')
if m.get('TemplateTag') is not None:
self.template_tag = m.get('TemplateTag')
if m.get('TemplateVersion') is not None:
self.template_version = m.get('TemplateVersion')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
return self
class GetTemplateResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: GetTemplateResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = GetTemplateResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class GetVersionRequest(TeaModel):
def __init__(
self,
flow_id: str = None,
version_id: str = None,
):
# The ID of the workflow.
self.flow_id = flow_id
# The ID of the version.
self.version_id = version_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.version_id is not None:
result['VersionId'] = self.version_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('VersionId') is not None:
self.version_id = m.get('VersionId')
return self
class GetVersionResponseBody(TeaModel):
def __init__(
self,
create_time: str = None,
definition: str = None,
flow_id: str = None,
region_id: str = None,
request_id: str = None,
update_time: str = None,
version_description: str = None,
version_id: str = None,
version_name: str = None,
version_status: str = None,
):
# The time when the version was created.
self.create_time = create_time
# The definition of the workflow to which the version belongs.
self.definition = definition
# The ID of the workflow to which the version belongs.
self.flow_id = flow_id
# The region where the workflow resides.
self.region_id = region_id
# The ID of the request.
self.request_id = request_id
# The time when the version was last updated.
self.update_time = update_time
# The description of the version.
self.version_description = version_description
# The ID of the version.
self.version_id = version_id
# The name of the version.
self.version_name = version_name
# The status of the version. **Enabled** indicates that the version is enabled.
self.version_status = version_status
def validate(self):
pass
def to_map(self):
_map = super().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.definition is not None:
result['Definition'] = self.definition
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.update_time is not None:
result['UpdateTime'] = self.update_time
if self.version_description is not None:
result['VersionDescription'] = self.version_description
if self.version_id is not None:
result['VersionId'] = self.version_id
if self.version_name is not None:
result['VersionName'] = self.version_name
if self.version_status is not None:
result['VersionStatus'] = self.version_status
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('Definition') is not None:
self.definition = m.get('Definition')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
if m.get('VersionDescription') is not None:
self.version_description = m.get('VersionDescription')
if m.get('VersionId') is not None:
self.version_id = m.get('VersionId')
if m.get('VersionName') is not None:
self.version_name = m.get('VersionName')
if m.get('VersionStatus') is not None:
self.version_status = m.get('VersionStatus')
return self
class GetVersionResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: GetVersionResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = GetVersionResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class GroupInvokeFlowRequest(TeaModel):
def __init__(
self,
client_token: str = None,
data: str = None,
flow_id: str = None,
group_key: str = None,
tags: str = None,
total_count: int = None,
):
# The client token that is used to ensure the idempotence of the request. You can use the client to generate the value, but you must ensure that it is unique among different requests. The token can only contain ASCII characters and cannot exceed 64 characters in length.
self.client_token = client_token
# The information required by the group execution. Set this parameter to a JSON array of strings in the following format:`{"Items": []}`. Each string provides the information required by one time of execution. The string must use the format of the Data parameter in the InvokeFlow operation.
self.data = data
# The ID of the workflow that you want to execute.
self.flow_id = flow_id
# The name of the group. The name must be unique among the groups.
self.group_key = group_key
# The tag that is attached to each time of execution. The value is a JSON array. The number of tags in the array is the same as the value of the TotalCount parameter.
self.tags = tags
# The number of times of execution. The value must be the same as the number of strings in the value of the Data parameter.
self.total_count = total_count
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.data is not None:
result['Data'] = self.data
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.group_key is not None:
result['GroupKey'] = self.group_key
if self.tags is not None:
result['Tags'] = self.tags
if self.total_count is not None:
result['TotalCount'] = self.total_count
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('GroupKey') is not None:
self.group_key = m.get('GroupKey')
if m.get('Tags') is not None:
self.tags = m.get('Tags')
if m.get('TotalCount') is not None:
self.total_count = m.get('TotalCount')
return self
class GroupInvokeFlowResponseBody(TeaModel):
def __init__(
self,
current_count: int = None,
group_invocation_id: str = None,
request_id: str = None,
status: str = None,
success: bool = None,
):
# The number of times of execution that are pending.
self.current_count = current_count
# The unique identifier of the execution.
self.group_invocation_id = group_invocation_id
# The ID of the request.
self.request_id = request_id
# The status of the group. Valid values:
#
# * New: The group is created and waiting to be executed.
# * Started: The group is being executed.
# * Canceled: The group was canceled.
# * Failed: The execution failed.
# * Completed: All the times of execution in the group are complete.
# * Unknown: The group status is uncertain. In this case, a system error may occur.
# * TimedOut: The execution timed out.
# * Paused: The execution was suspended.
self.status = status
# Indicates whether the operation was successful.
#
# * **true**: The workflow execution is triggered.
# * **false**: The workflow execution failed to be triggered.
#
# > : You can call the **GetInvocationLog** operation to check whether the workflow execution is successful.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.current_count is not None:
result['CurrentCount'] = self.current_count
if self.group_invocation_id is not None:
result['GroupInvocationId'] = self.group_invocation_id
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.status is not None:
result['Status'] = self.status
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CurrentCount') is not None:
self.current_count = m.get('CurrentCount')
if m.get('GroupInvocationId') is not None:
self.group_invocation_id = m.get('GroupInvocationId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Status') is not None:
self.status = m.get('Status')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class GroupInvokeFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: GroupInvokeFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = GroupInvokeFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class InvokeFlowRequest(TeaModel):
def __init__(
self,
client_token: str = None,
data: str = None,
flow_id: str = None,
parameters: str = None,
):
# The token that is used to guarantee idempotence to avoid repeated operations.
self.client_token = client_token
# The data for invoking the workflow.
self.data = data
# The parameters required by the template, which must be in JSON format.
self.flow_id = flow_id
# The input parameters required by the trigger of the workflow execution, which must be in JSON format.
self.parameters = parameters
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.client_token is not None:
result['ClientToken'] = self.client_token
if self.data is not None:
result['Data'] = self.data
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.parameters is not None:
result['Parameters'] = self.parameters
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('ClientToken') is not None:
self.client_token = m.get('ClientToken')
if m.get('Data') is not None:
self.data = m.get('Data')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('Parameters') is not None:
self.parameters = m.get('Parameters')
return self
class InvokeFlowResponseBody(TeaModel):
def __init__(
self,
invocation_id: str = None,
request_id: str = None,
success: bool = None,
):
# The unique identifier of the execution.
self.invocation_id = invocation_id
# The ID for this request.
self.request_id = request_id
# Indicates whether the workflow execution was triggered.
#
# * **true**: The workflow execution was triggered
# * **false**: The workflow execution failed to be triggered.
#
# > : You can call the **GetInvocationLog** operation to check whether the workflow execution is successful.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.invocation_id is not None:
result['InvocationId'] = self.invocation_id
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('InvocationId') is not None:
self.invocation_id = m.get('InvocationId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class InvokeFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: InvokeFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = InvokeFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListFlowsRequest(TeaModel):
def __init__(
self,
filter: str = None,
flow_name: str = None,
page_number: int = None,
page_size: int = None,
resource_group_id: str = None,
):
# The filter condition, which is in the JSON format of {"key":"value"}. Example: {"key1":"value1"}
self.filter = filter
# The name of the workflow.
self.flow_name = flow_name
# The page number of the current page. Minimum value: 1. Default value: 1.
self.page_number = page_number
# Specifies the number of workflows to return on each page. A page can contain a maximum of 100 workflows. Default value: 10.
self.page_size = page_size
# The ID of the resource group.
self.resource_group_id = resource_group_id
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.filter is not None:
result['Filter'] = self.filter
if self.flow_name is not None:
result['FlowName'] = self.flow_name
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('Filter') is not None:
self.filter = m.get('Filter')
if m.get('FlowName') is not None:
self.flow_name = m.get('FlowName')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
return self
class ListFlowsResponseBodyFlows(TeaModel):
def __init__(
self,
create_time: str = None,
flow_description: str = None,
flow_edit_mode: str = None,
flow_id: str = None,
flow_name: str = None,
flow_source: str = None,
flow_status: str = None,
region_id: str = None,
resource_group_id: str = None,
template_id: str = None,
update_time: str = None,
version_id: str = None,
):
# The time when the workflow was created.
self.create_time = create_time
# The description of the workflow.
self.flow_description = flow_description
# The edit mode of the workflow.
self.flow_edit_mode = flow_edit_mode
# The ID of the workflow.
self.flow_id = flow_id
# The name of the workflow.
self.flow_name = flow_name
# The source of the workflow.
self.flow_source = flow_source
# The status of the workflow. Valid values:
#
# * **Enabled**: The workflow is enabled.
# * **Disabled**: The workflow is disabled.
self.flow_status = flow_status
# The region to which the workflow belongs.
self.region_id = region_id
# The ID of the resource group.
self.resource_group_id = resource_group_id
# The template ID. You can call the ListTemplates operation to obtain the template ID.
self.template_id = template_id
# The time when the workflow was last updated.
self.update_time = update_time
# The latest version of the workflow.
self.version_id = version_id
def validate(self):
pass
def to_map(self):
_map = super().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.flow_description is not None:
result['FlowDescription'] = self.flow_description
if self.flow_edit_mode is not None:
result['FlowEditMode'] = self.flow_edit_mode
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.flow_name is not None:
result['FlowName'] = self.flow_name
if self.flow_source is not None:
result['FlowSource'] = self.flow_source
if self.flow_status is not None:
result['FlowStatus'] = self.flow_status
if self.region_id is not None:
result['RegionId'] = self.region_id
if self.resource_group_id is not None:
result['ResourceGroupId'] = self.resource_group_id
if self.template_id is not None:
result['TemplateId'] = self.template_id
if self.update_time is not None:
result['UpdateTime'] = self.update_time
if self.version_id is not None:
result['VersionId'] = self.version_id
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('FlowDescription') is not None:
self.flow_description = m.get('FlowDescription')
if m.get('FlowEditMode') is not None:
self.flow_edit_mode = m.get('FlowEditMode')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('FlowName') is not None:
self.flow_name = m.get('FlowName')
if m.get('FlowSource') is not None:
self.flow_source = m.get('FlowSource')
if m.get('FlowStatus') is not None:
self.flow_status = m.get('FlowStatus')
if m.get('RegionId') is not None:
self.region_id = m.get('RegionId')
if m.get('ResourceGroupId') is not None:
self.resource_group_id = m.get('ResourceGroupId')
if m.get('TemplateId') is not None:
self.template_id = m.get('TemplateId')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
if m.get('VersionId') is not None:
self.version_id = m.get('VersionId')
return self
class ListFlowsResponseBody(TeaModel):
def __init__(
self,
flows: List[ListFlowsResponseBodyFlows] = None,
request_id: str = None,
total_count: int = None,
):
# A list of workflows.
self.flows = flows
# The ID of the request.
self.request_id = request_id
# The total number of workflows in the current region.
self.total_count = total_count
def validate(self):
if self.flows:
for k in self.flows:
if k:
k.validate()
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
result['Flows'] = []
if self.flows is not None:
for k in self.flows:
result['Flows'].append(k.to_map() if k else None)
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total_count is not None:
result['TotalCount'] = self.total_count
return result
def from_map(self, m: dict = None):
m = m or dict()
self.flows = []
if m.get('Flows') is not None:
for k in m.get('Flows'):
temp_model = ListFlowsResponseBodyFlows()
self.flows.append(temp_model.from_map(k))
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('TotalCount') is not None:
self.total_count = m.get('TotalCount')
return self
class ListFlowsResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: ListFlowsResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = ListFlowsResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListTagResourcesRequestTag(TeaModel):
def __init__(
self,
key: str = None,
value: str = None,
):
# The key of the tag.
self.key = key
# The value of the tag.
self.value = value
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.key is not None:
result['Key'] = self.key
if self.value is not None:
result['Value'] = self.value
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('Key') is not None:
self.key = m.get('Key')
if m.get('Value') is not None:
self.value = m.get('Value')
return self
class ListTagResourcesRequest(TeaModel):
def __init__(
self,
max_results: int = None,
next_token: str = None,
resource_id: List[str] = None,
resource_type: str = None,
tag: List[ListTagResourcesRequestTag] = None,
):
# The maximum number of results to return on each page.
self.max_results = max_results
# The token that is used to start the next query.
self.next_token = next_token
# A list of resource IDs.
self.resource_id = resource_id
# The type of the resources. Set the value to ALIYUN::LC::FLOW.
#
# * ALIYUN::LC::FLOW indicates Logic Composer workflows.
self.resource_type = resource_type
# A list of tags that are attached to the resources. A list can contain a maximum of 20 tags.
self.tag = tag
def validate(self):
if self.tag:
for k in self.tag:
if k:
k.validate()
def to_map(self):
_map = super().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.resource_id is not None:
result['ResourceId'] = self.resource_id
if self.resource_type is not None:
result['ResourceType'] = self.resource_type
result['Tag'] = []
if self.tag is not None:
for k in self.tag:
result['Tag'].append(k.to_map() if k else None)
return result
def from_map(self, m: dict = 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('ResourceId') is not None:
self.resource_id = m.get('ResourceId')
if m.get('ResourceType') is not None:
self.resource_type = m.get('ResourceType')
self.tag = []
if m.get('Tag') is not None:
for k in m.get('Tag'):
temp_model = ListTagResourcesRequestTag()
self.tag.append(temp_model.from_map(k))
return self
class ListTagResourcesResponseBodyTagResources(TeaModel):
def __init__(
self,
resource_id: str = None,
resource_type: str = None,
tag_key: str = None,
tag_value: str = None,
):
# The ID of the resource.
self.resource_id = resource_id
# The type of the resource.
#
# * Valid value: ALIYUN::LC::FLOW
self.resource_type = resource_type
# The key of the tag.
self.tag_key = tag_key
# The value of the tag.
self.tag_value = tag_value
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.resource_id is not None:
result['ResourceId'] = self.resource_id
if self.resource_type is not None:
result['ResourceType'] = self.resource_type
if self.tag_key is not None:
result['TagKey'] = self.tag_key
if self.tag_value is not None:
result['TagValue'] = self.tag_value
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('ResourceId') is not None:
self.resource_id = m.get('ResourceId')
if m.get('ResourceType') is not None:
self.resource_type = m.get('ResourceType')
if m.get('TagKey') is not None:
self.tag_key = m.get('TagKey')
if m.get('TagValue') is not None:
self.tag_value = m.get('TagValue')
return self
class ListTagResourcesResponseBody(TeaModel):
def __init__(
self,
next_token: str = None,
request_id: str = None,
tag_resources: List[ListTagResourcesResponseBodyTagResources] = None,
total_count: int = None,
):
# The token that is used to start the next query.
self.next_token = next_token
# The ID of the request.
self.request_id = request_id
# The mappings between resources and tags.
self.tag_resources = tag_resources
# The total number of resources.
self.total_count = total_count
def validate(self):
if self.tag_resources:
for k in self.tag_resources:
if k:
k.validate()
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.next_token is not None:
result['NextToken'] = self.next_token
if self.request_id is not None:
result['RequestId'] = self.request_id
result['TagResources'] = []
if self.tag_resources is not None:
for k in self.tag_resources:
result['TagResources'].append(k.to_map() if k else None)
if self.total_count is not None:
result['TotalCount'] = self.total_count
return result
def from_map(self, m: dict = None):
m = m or dict()
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')
self.tag_resources = []
if m.get('TagResources') is not None:
for k in m.get('TagResources'):
temp_model = ListTagResourcesResponseBodyTagResources()
self.tag_resources.append(temp_model.from_map(k))
if m.get('TotalCount') is not None:
self.total_count = m.get('TotalCount')
return self
class ListTagResourcesResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: ListTagResourcesResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = ListTagResourcesResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListTemplatesRequest(TeaModel):
def __init__(
self,
lang: str = None,
name: str = None,
page_number: int = None,
page_size: int = None,
tag: str = None,
):
# The language that is used in the templates.
self.lang = lang
# The keyword that is used to search for templates. This parameter is invalid if you specify a tag.
self.name = name
# The page number of current page.
self.page_number = page_number
# The number of templates on each page. A page can contain a maximum of 100 templates. Default value: 10.
self.page_size = page_size
# The tag that is used to search for templates.
self.tag = tag
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.lang is not None:
result['Lang'] = self.lang
if self.name is not None:
result['Name'] = self.name
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
if self.tag is not None:
result['Tag'] = self.tag
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('Lang') is not None:
self.lang = m.get('Lang')
if m.get('Name') is not None:
self.name = m.get('Name')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
if m.get('Tag') is not None:
self.tag = m.get('Tag')
return self
class ListTemplatesResponseBodyTemplates(TeaModel):
def __init__(
self,
create_time: str = None,
template_connector: str = None,
template_creator: str = None,
template_description: str = None,
template_id: str = None,
template_locale: str = None,
template_name: str = None,
template_overview: str = None,
template_summary: str = None,
template_summary_en: str = None,
template_tag: str = None,
template_version: int = None,
update_time: str = None,
):
# The time when the template was created.
self.create_time = create_time
# A list of connectors that are used in the template. The connectors are separated by commas.
self.template_connector = template_connector
# The publisher of the template.
self.template_creator = template_creator
# A brief introduction to the template.
self.template_description = template_description
# The ID of the template.
self.template_id = template_id
# The language that is used in the template. Chinese and English are supported.
self.template_locale = template_locale
# The name of the template.
self.template_name = template_name
# An overview of the template, which is a JSON string.
self.template_overview = template_overview
# A description of the template.
self.template_summary = template_summary
# A brief introduction to the template.
self.template_summary_en = template_summary_en
# The tag of the template.
self.template_tag = template_tag
# The version of the template, which is a number that increments from 0.
self.template_version = template_version
# The time when the template was last updated.
self.update_time = update_time
def validate(self):
pass
def to_map(self):
_map = super().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.template_connector is not None:
result['TemplateConnector'] = self.template_connector
if self.template_creator is not None:
result['TemplateCreator'] = self.template_creator
if self.template_description is not None:
result['TemplateDescription'] = self.template_description
if self.template_id is not None:
result['TemplateId'] = self.template_id
if self.template_locale is not None:
result['TemplateLocale'] = self.template_locale
if self.template_name is not None:
result['TemplateName'] = self.template_name
if self.template_overview is not None:
result['TemplateOverview'] = self.template_overview
if self.template_summary is not None:
result['TemplateSummary'] = self.template_summary
if self.template_summary_en is not None:
result['TemplateSummaryEn'] = self.template_summary_en
if self.template_tag is not None:
result['TemplateTag'] = self.template_tag
if self.template_version is not None:
result['TemplateVersion'] = self.template_version
if self.update_time is not None:
result['UpdateTime'] = self.update_time
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('TemplateConnector') is not None:
self.template_connector = m.get('TemplateConnector')
if m.get('TemplateCreator') is not None:
self.template_creator = m.get('TemplateCreator')
if m.get('TemplateDescription') is not None:
self.template_description = m.get('TemplateDescription')
if m.get('TemplateId') is not None:
self.template_id = m.get('TemplateId')
if m.get('TemplateLocale') is not None:
self.template_locale = m.get('TemplateLocale')
if m.get('TemplateName') is not None:
self.template_name = m.get('TemplateName')
if m.get('TemplateOverview') is not None:
self.template_overview = m.get('TemplateOverview')
if m.get('TemplateSummary') is not None:
self.template_summary = m.get('TemplateSummary')
if m.get('TemplateSummaryEn') is not None:
self.template_summary_en = m.get('TemplateSummaryEn')
if m.get('TemplateTag') is not None:
self.template_tag = m.get('TemplateTag')
if m.get('TemplateVersion') is not None:
self.template_version = m.get('TemplateVersion')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
return self
class ListTemplatesResponseBody(TeaModel):
def __init__(
self,
request_id: str = None,
templates: List[ListTemplatesResponseBodyTemplates] = None,
total_count: int = None,
):
# The unique identifier of the request.
self.request_id = request_id
# A list of templates.
self.templates = templates
# The total number of templates.
self.total_count = total_count
def validate(self):
if self.templates:
for k in self.templates:
if k:
k.validate()
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.request_id is not None:
result['RequestId'] = self.request_id
result['Templates'] = []
if self.templates is not None:
for k in self.templates:
result['Templates'].append(k.to_map() if k else None)
if self.total_count is not None:
result['TotalCount'] = self.total_count
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
self.templates = []
if m.get('Templates') is not None:
for k in m.get('Templates'):
temp_model = ListTemplatesResponseBodyTemplates()
self.templates.append(temp_model.from_map(k))
if m.get('TotalCount') is not None:
self.total_count = m.get('TotalCount')
return self
class ListTemplatesResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: ListTemplatesResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = ListTemplatesResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class ListVersionsRequest(TeaModel):
def __init__(
self,
flow_id: str = None,
page_number: int = None,
page_size: int = None,
):
# The ID of the workflow whose versions you want to query.
self.flow_id = flow_id
# The page number of the page to return. The value must be an integer that is greater than 0. Default value: 1.
self.page_number = page_number
# The number of versions to return on each page. One page contains a maximum of 100 versions. Default value: 10.
self.page_size = page_size
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.page_number is not None:
result['PageNumber'] = self.page_number
if self.page_size is not None:
result['PageSize'] = self.page_size
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('PageNumber') is not None:
self.page_number = m.get('PageNumber')
if m.get('PageSize') is not None:
self.page_size = m.get('PageSize')
return self
class ListVersionsResponseBodyVersions(TeaModel):
def __init__(
self,
create_time: str = None,
flow_id: str = None,
update_time: str = None,
version_id: str = None,
version_name: str = None,
version_number: int = None,
version_status: str = None,
):
# The time when the version was created.
self.create_time = create_time
# The ID of the workflow to which the version belongs.
self.flow_id = flow_id
# The time when the version was last updated.
self.update_time = update_time
# The ID of the version.
self.version_id = version_id
# The name of the version.
self.version_name = version_name
# The number of the version. Increment from 1.
self.version_number = version_number
# The status of the version. **Enabled** indicates that the version is enabled.
self.version_status = version_status
def validate(self):
pass
def to_map(self):
_map = super().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.flow_id is not None:
result['FlowId'] = self.flow_id
if self.update_time is not None:
result['UpdateTime'] = self.update_time
if self.version_id is not None:
result['VersionId'] = self.version_id
if self.version_name is not None:
result['VersionName'] = self.version_name
if self.version_number is not None:
result['VersionNumber'] = self.version_number
if self.version_status is not None:
result['VersionStatus'] = self.version_status
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CreateTime') is not None:
self.create_time = m.get('CreateTime')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('UpdateTime') is not None:
self.update_time = m.get('UpdateTime')
if m.get('VersionId') is not None:
self.version_id = m.get('VersionId')
if m.get('VersionName') is not None:
self.version_name = m.get('VersionName')
if m.get('VersionNumber') is not None:
self.version_number = m.get('VersionNumber')
if m.get('VersionStatus') is not None:
self.version_status = m.get('VersionStatus')
return self
class ListVersionsResponseBody(TeaModel):
def __init__(
self,
request_id: str = None,
total_count: int = None,
versions: List[ListVersionsResponseBodyVersions] = None,
):
# The ID of the request.
self.request_id = request_id
# The total number of versions of the workflow.
self.total_count = total_count
# A list of the versions.
self.versions = versions
def validate(self):
if self.versions:
for k in self.versions:
if k:
k.validate()
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.total_count is not None:
result['TotalCount'] = self.total_count
result['Versions'] = []
if self.versions is not None:
for k in self.versions:
result['Versions'].append(k.to_map() if k else None)
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('TotalCount') is not None:
self.total_count = m.get('TotalCount')
self.versions = []
if m.get('Versions') is not None:
for k in m.get('Versions'):
temp_model = ListVersionsResponseBodyVersions()
self.versions.append(temp_model.from_map(k))
return self
class ListVersionsResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: ListVersionsResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = ListVersionsResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class TagResourcesRequestTag(TeaModel):
def __init__(
self,
key: str = None,
value: str = None,
):
# The key of the tag.
self.key = key
# The value of the tag.
self.value = value
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.key is not None:
result['Key'] = self.key
if self.value is not None:
result['Value'] = self.value
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('Key') is not None:
self.key = m.get('Key')
if m.get('Value') is not None:
self.value = m.get('Value')
return self
class TagResourcesRequest(TeaModel):
def __init__(
self,
resource_id: List[str] = None,
resource_type: str = None,
tag: List[TagResourcesRequestTag] = None,
):
# Specifies a maximum of 50 resource IDs.
self.resource_id = resource_id
# The type of the resources. Set the value to ALIYUN::LC::FLOW.
#
# * ALIYUN::LC::FLOW indicates Logic Composer workflows.
self.resource_type = resource_type
# Specifies a list of tags that you want to attach to the resources.
self.tag = tag
def validate(self):
if self.tag:
for k in self.tag:
if k:
k.validate()
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.resource_id is not None:
result['ResourceId'] = self.resource_id
if self.resource_type is not None:
result['ResourceType'] = self.resource_type
result['Tag'] = []
if self.tag is not None:
for k in self.tag:
result['Tag'].append(k.to_map() if k else None)
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('ResourceId') is not None:
self.resource_id = m.get('ResourceId')
if m.get('ResourceType') is not None:
self.resource_type = m.get('ResourceType')
self.tag = []
if m.get('Tag') is not None:
for k in m.get('Tag'):
temp_model = TagResourcesRequestTag()
self.tag.append(temp_model.from_map(k))
return self
class TagResourcesResponseBody(TeaModel):
def __init__(
self,
request_id: str = None,
success: bool = None,
):
# The ID of the request.
self.request_id = request_id
# Indicates whether the request was successful.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class TagResourcesResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: TagResourcesResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = TagResourcesResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class UntagResourcesRequest(TeaModel):
def __init__(
self,
all: bool = None,
resource_id: List[str] = None,
resource_type: str = None,
tag_key: List[str] = None,
):
# 系统规定参数。取值：UntagResources。
self.all = all
# The type of the resources. Set the value to ALIYUN::LC::FLOW.
#
# * ALIYUN::LC::FLOW indicates Logic Composer workflows.
self.resource_id = resource_id
# system
self.resource_type = resource_type
# Specifies a maximum of 50 resource IDs.
self.tag_key = tag_key
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.all is not None:
result['All'] = self.all
if self.resource_id is not None:
result['ResourceId'] = self.resource_id
if self.resource_type is not None:
result['ResourceType'] = self.resource_type
if self.tag_key is not None:
result['TagKey'] = self.tag_key
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('All') is not None:
self.all = m.get('All')
if m.get('ResourceId') is not None:
self.resource_id = m.get('ResourceId')
if m.get('ResourceType') is not None:
self.resource_type = m.get('ResourceType')
if m.get('TagKey') is not None:
self.tag_key = m.get('TagKey')
return self
class UntagResourcesResponseBody(TeaModel):
def __init__(
self,
request_id: str = None,
success: bool = None,
):
# Indicates whether the call was successful.
self.request_id = request_id
# The ID of the request.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class UntagResourcesResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: UntagResourcesResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = UntagResourcesResponseBody()
self.body = temp_model.from_map(m['body'])
return self
class UpdateFlowRequest(TeaModel):
def __init__(
self,
definition: str = None,
flow_description: str = None,
flow_id: str = None,
flow_name: str = None,
):
# The new definition that you want to specify for the workflow.
self.definition = definition
# The new description that you want to specify for the workflow.
self.flow_description = flow_description
# The ID of the workflow whose information you want to update.
self.flow_id = flow_id
# The new name that you want to specify for the workflow.
self.flow_name = flow_name
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.definition is not None:
result['Definition'] = self.definition
if self.flow_description is not None:
result['FlowDescription'] = self.flow_description
if self.flow_id is not None:
result['FlowId'] = self.flow_id
if self.flow_name is not None:
result['FlowName'] = self.flow_name
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('Definition') is not None:
self.definition = m.get('Definition')
if m.get('FlowDescription') is not None:
self.flow_description = m.get('FlowDescription')
if m.get('FlowId') is not None:
self.flow_id = m.get('FlowId')
if m.get('FlowName') is not None:
self.flow_name = m.get('FlowName')
return self
class UpdateFlowResponseBody(TeaModel):
def __init__(
self,
current_version_id: int = None,
request_id: str = None,
success: bool = None,
):
# The version ID of the workflow after the update.
self.current_version_id = current_version_id
# The ID of the request.
self.request_id = request_id
# Indicates whether the operation was successful. Valid values:
#
# * **true**: The operation was successful.
# * **false**: The operation failed.
self.success = success
def validate(self):
pass
def to_map(self):
_map = super().to_map()
if _map is not None:
return _map
result = dict()
if self.current_version_id is not None:
result['CurrentVersionId'] = self.current_version_id
if self.request_id is not None:
result['RequestId'] = self.request_id
if self.success is not None:
result['Success'] = self.success
return result
def from_map(self, m: dict = None):
m = m or dict()
if m.get('CurrentVersionId') is not None:
self.current_version_id = m.get('CurrentVersionId')
if m.get('RequestId') is not None:
self.request_id = m.get('RequestId')
if m.get('Success') is not None:
self.success = m.get('Success')
return self
class UpdateFlowResponse(TeaModel):
def __init__(
self,
headers: Dict[str, str] = None,
status_code: int = None,
body: UpdateFlowResponseBody = None,
):
self.headers = headers
self.status_code = status_code
self.body = body
def validate(self):
self.validate_required(self.headers, 'headers')
self.validate_required(self.status_code, 'status_code')
self.validate_required(self.body, 'body')
if self.body:
self.body.validate()
def to_map(self):
_map = super().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: dict = 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 = UpdateFlowResponseBody()
self.body = temp_model.from_map(m['body'])
return self