Skip to content

[AutoPR datalake-analytics/data-plane] Add hierarchyQueueNode into JobInformation(Basic) #3369

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

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 @@ -70,6 +70,10 @@ class JobInformation(JobInformationBasic):
:param tags: The key-value pairs used to add additional metadata to the
job information. (Only for use internally with Scope job type.)
:type tags: dict[str, str]
:ivar hierarchy_queue_node: the name of hierarchy queue node this job is
assigned to, Null if job has not been assigned yet or the account doesn't
have hierarchy queue.
:vartype hierarchy_queue_node: str
:ivar error_message: The error message details for the job, if the job
failed.
:vartype error_message:
Expand All @@ -94,6 +98,7 @@ class JobInformation(JobInformationBasic):
'state': {'readonly': True},
'result': {'readonly': True},
'log_folder': {'readonly': True},
'hierarchy_queue_node': {'readonly': True},
'error_message': {'readonly': True},
'state_audit_records': {'readonly': True},
'properties': {'required': True},
Expand All @@ -116,6 +121,7 @@ class JobInformation(JobInformationBasic):
'log_file_patterns': {'key': 'logFilePatterns', 'type': '[str]'},
'related': {'key': 'related', 'type': 'JobRelationshipProperties'},
'tags': {'key': 'tags', 'type': '{str}'},
'hierarchy_queue_node': {'key': 'hierarchyQueueNode', 'type': 'str'},
'error_message': {'key': 'errorMessage', 'type': '[JobErrorDetails]'},
'state_audit_records': {'key': 'stateAuditRecords', 'type': '[JobStateAuditRecord]'},
'properties': {'key': 'properties', 'type': 'JobProperties'},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,10 @@ class JobInformationBasic(Model):
:param tags: The key-value pairs used to add additional metadata to the
job information. (Only for use internally with Scope job type.)
:type tags: dict[str, str]
:ivar hierarchy_queue_node: the name of hierarchy queue node this job is
assigned to, Null if job has not been assigned yet or the account doesn't
have hierarchy queue.
:vartype hierarchy_queue_node: str
"""

_validation = {
Expand All @@ -83,6 +87,7 @@ class JobInformationBasic(Model):
'state': {'readonly': True},
'result': {'readonly': True},
'log_folder': {'readonly': True},
'hierarchy_queue_node': {'readonly': True},
}

_attribute_map = {
Expand All @@ -102,6 +107,7 @@ class JobInformationBasic(Model):
'log_file_patterns': {'key': 'logFilePatterns', 'type': '[str]'},
'related': {'key': 'related', 'type': 'JobRelationshipProperties'},
'tags': {'key': 'tags', 'type': '{str}'},
'hierarchy_queue_node': {'key': 'hierarchyQueueNode', 'type': 'str'},
}

def __init__(self, **kwargs):
Expand All @@ -122,3 +128,4 @@ def __init__(self, **kwargs):
self.log_file_patterns = kwargs.get('log_file_patterns', None)
self.related = kwargs.get('related', None)
self.tags = kwargs.get('tags', None)
self.hierarchy_queue_node = None
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,10 @@ class JobInformationBasic(Model):
:param tags: The key-value pairs used to add additional metadata to the
job information. (Only for use internally with Scope job type.)
:type tags: dict[str, str]
:ivar hierarchy_queue_node: the name of hierarchy queue node this job is
assigned to, Null if job has not been assigned yet or the account doesn't
have hierarchy queue.
:vartype hierarchy_queue_node: str
"""

_validation = {
Expand All @@ -83,6 +87,7 @@ class JobInformationBasic(Model):
'state': {'readonly': True},
'result': {'readonly': True},
'log_folder': {'readonly': True},
'hierarchy_queue_node': {'readonly': True},
}

_attribute_map = {
Expand All @@ -102,6 +107,7 @@ class JobInformationBasic(Model):
'log_file_patterns': {'key': 'logFilePatterns', 'type': '[str]'},
'related': {'key': 'related', 'type': 'JobRelationshipProperties'},
'tags': {'key': 'tags', 'type': '{str}'},
'hierarchy_queue_node': {'key': 'hierarchyQueueNode', 'type': 'str'},
}

def __init__(self, *, name: str, type, degree_of_parallelism: int=1, priority: int=None, log_file_patterns=None, related=None, tags=None, **kwargs) -> None:
Expand All @@ -122,3 +128,4 @@ def __init__(self, *, name: str, type, degree_of_parallelism: int=1, priority: i
self.log_file_patterns = log_file_patterns
self.related = related
self.tags = tags
self.hierarchy_queue_node = None
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,10 @@ class JobInformation(JobInformationBasic):
:param tags: The key-value pairs used to add additional metadata to the
job information. (Only for use internally with Scope job type.)
:type tags: dict[str, str]
:ivar hierarchy_queue_node: the name of hierarchy queue node this job is
assigned to, Null if job has not been assigned yet or the account doesn't
have hierarchy queue.
:vartype hierarchy_queue_node: str
:ivar error_message: The error message details for the job, if the job
failed.
:vartype error_message:
Expand All @@ -94,6 +98,7 @@ class JobInformation(JobInformationBasic):
'state': {'readonly': True},
'result': {'readonly': True},
'log_folder': {'readonly': True},
'hierarchy_queue_node': {'readonly': True},
'error_message': {'readonly': True},
'state_audit_records': {'readonly': True},
'properties': {'required': True},
Expand All @@ -116,6 +121,7 @@ class JobInformation(JobInformationBasic):
'log_file_patterns': {'key': 'logFilePatterns', 'type': '[str]'},
'related': {'key': 'related', 'type': 'JobRelationshipProperties'},
'tags': {'key': 'tags', 'type': '{str}'},
'hierarchy_queue_node': {'key': 'hierarchyQueueNode', 'type': 'str'},
'error_message': {'key': 'errorMessage', 'type': '[JobErrorDetails]'},
'state_audit_records': {'key': 'stateAuditRecords', 'type': '[JobStateAuditRecord]'},
'properties': {'key': 'properties', 'type': 'JobProperties'},
Expand Down