Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[AutoPR datamigration/resource-manager] add clientData properties to data migration tasks #3796

Merged
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -91,6 +91,7 @@ def __init__(
super(DataMigrationServiceClient, self).__init__(self.config.credentials, self.config)

client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
self.api_version = '2018-07-15-preview'
self._serialize = Serializer(client_models)
self._deserialize = Deserializer(client_models)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToMongoDbTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input:
Expand All @@ -50,6 +53,7 @@ class ConnectToMongoDbTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'MongoDbConnectionInfo'},
'output': {'key': 'output', 'type': '[MongoDbClusterInfo]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToMongoDbTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input:
Expand All @@ -50,13 +53,14 @@ class ConnectToMongoDbTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'MongoDbConnectionInfo'},
'output': {'key': 'output', 'type': '[MongoDbClusterInfo]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToMongoDbTaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToMongoDbTaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'Connect.MongoDb'
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,9 @@ class ConnectToSourceMySqlTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -51,6 +54,7 @@ class ConnectToSourceMySqlTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToSourceMySqlTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToSourceNonSqlTaskOutput]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,9 @@ class ConnectToSourceMySqlTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -51,13 +54,14 @@ class ConnectToSourceMySqlTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToSourceMySqlTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToSourceNonSqlTaskOutput]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToSourceMySqlTaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToSourceMySqlTaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'ConnectToSource.MySql'
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToSourceSqlServerSyncTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,6 +55,7 @@ class ConnectToSourceSqlServerSyncTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToSourceSqlServerTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToSourceSqlServerTaskOutput]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToSourceSqlServerSyncTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,13 +55,14 @@ class ConnectToSourceSqlServerSyncTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToSourceSqlServerTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToSourceSqlServerTaskOutput]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToSourceSqlServerSyncTaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToSourceSqlServerSyncTaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'ConnectToSource.SqlServer.Sync'
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToSourceSqlServerTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,6 +55,7 @@ class ConnectToSourceSqlServerTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToSourceSqlServerTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToSourceSqlServerTaskOutput]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToSourceSqlServerTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,13 +55,14 @@ class ConnectToSourceSqlServerTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToSourceSqlServerTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToSourceSqlServerTaskOutput]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToSourceSqlServerTaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToSourceSqlServerTaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'ConnectToSource.SqlServer'
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetAzureDbForMySqlTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,6 +55,7 @@ class ConnectToTargetAzureDbForMySqlTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetAzureDbForMySqlTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetAzureDbForMySqlTaskOutput]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetAzureDbForMySqlTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,13 +55,14 @@ class ConnectToTargetAzureDbForMySqlTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetAzureDbForMySqlTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetAzureDbForMySqlTaskOutput]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToTargetAzureDbForMySqlTaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToTargetAzureDbForMySqlTaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'ConnectToTarget.AzureDbForMySql'
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetSqlDbTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,6 +55,7 @@ class ConnectToTargetSqlDbTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetSqlDbTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetSqlDbTaskOutput]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetSqlDbTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,13 +55,14 @@ class ConnectToTargetSqlDbTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetSqlDbTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetSqlDbTaskOutput]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToTargetSqlDbTaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToTargetSqlDbTaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'ConnectToTarget.SqlDb'
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetSqlMITaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,6 +55,7 @@ class ConnectToTargetSqlMITaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetSqlMITaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetSqlMITaskOutput]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetSqlMITaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,13 +55,14 @@ class ConnectToTargetSqlMITaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetSqlMITaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetSqlMITaskOutput]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToTargetSqlMITaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToTargetSqlMITaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'ConnectToTarget.AzureSqlDbMI'
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetSqlSqlDbSyncTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,6 +55,7 @@ class ConnectToTargetSqlSqlDbSyncTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetSqlSqlDbSyncTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetSqlDbTaskOutput]'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,9 @@ class ConnectToTargetSqlSqlDbSyncTaskProperties(ProjectTaskProperties):
:ivar commands: Array of command properties.
:vartype commands:
list[~azure.mgmt.datamigration.models.CommandProperties]
:param client_data: Key value pairs of client data to attach meta data
information to task
:type client_data: dict[str, str]
:param task_type: Required. Constant filled by server.
:type task_type: str
:param input: Task input
Expand All @@ -52,13 +55,14 @@ class ConnectToTargetSqlSqlDbSyncTaskProperties(ProjectTaskProperties):
'errors': {'key': 'errors', 'type': '[ODataError]'},
'state': {'key': 'state', 'type': 'str'},
'commands': {'key': 'commands', 'type': '[CommandProperties]'},
'client_data': {'key': 'clientData', 'type': '{str}'},
'task_type': {'key': 'taskType', 'type': 'str'},
'input': {'key': 'input', 'type': 'ConnectToTargetSqlSqlDbSyncTaskInput'},
'output': {'key': 'output', 'type': '[ConnectToTargetSqlDbTaskOutput]'},
}

def __init__(self, *, input=None, **kwargs) -> None:
super(ConnectToTargetSqlSqlDbSyncTaskProperties, self).__init__(**kwargs)
def __init__(self, *, client_data=None, input=None, **kwargs) -> None:
super(ConnectToTargetSqlSqlDbSyncTaskProperties, self).__init__(client_data=client_data, **kwargs)
self.input = input
self.output = None
self.task_type = 'ConnectToTarget.SqlDb.Sync'
Loading