1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
# coding=utf-8
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
#
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.
# --------------------------------------------------------------------------
from msrest.serialization import Model
class JobScheduleStatistics(Model):
"""Resource usage statistics for a job schedule.
All required parameters must be populated in order to send to Azure.
:param url: Required. The URL of the statistics.
:type url: str
:param start_time: Required. The start time of the time range covered by
the statistics.
:type start_time: datetime
:param last_update_time: Required. The time at which the statistics were
last updated. All statistics are limited to the range between startTime
and lastUpdateTime.
:type last_update_time: datetime
:param user_cpu_time: Required. The total user mode CPU time (summed
across all cores and all compute nodes) consumed by all tasks in all jobs
created under the schedule.
:type user_cpu_time: timedelta
:param kernel_cpu_time: Required. The total kernel mode CPU time (summed
across all cores and all compute nodes) consumed by all tasks in all jobs
created under the schedule.
:type kernel_cpu_time: timedelta
:param wall_clock_time: Required. The total wall clock time of all the
tasks in all the jobs created under the schedule. The wall clock time is
the elapsed time from when the task started running on a compute node to
when it finished (or to the last time the statistics were updated, if the
task had not finished by then). If a task was retried, this includes the
wall clock time of all the task retries.
:type wall_clock_time: timedelta
:param read_iops: Required. The total number of disk read operations made
by all tasks in all jobs created under the schedule.
:type read_iops: long
:param write_iops: Required. The total number of disk write operations
made by all tasks in all jobs created under the schedule.
:type write_iops: long
:param read_io_gi_b: Required. The total gibibytes read from disk by all
tasks in all jobs created under the schedule.
:type read_io_gi_b: float
:param write_io_gi_b: Required. The total gibibytes written to disk by all
tasks in all jobs created under the schedule.
:type write_io_gi_b: float
:param num_succeeded_tasks: Required. The total number of tasks
successfully completed during the given time range in jobs created under
the schedule. A task completes successfully if it returns exit code 0.
:type num_succeeded_tasks: long
:param num_failed_tasks: Required. The total number of tasks that failed
during the given time range in jobs created under the schedule. A task
fails if it exhausts its maximum retry count without returning exit code
0.
:type num_failed_tasks: long
:param num_task_retries: Required. The total number of retries during the
given time range on all tasks in all jobs created under the schedule.
:type num_task_retries: long
:param wait_time: Required. The total wait time of all tasks in all jobs
created under the schedule. The wait time for a task is defined as the
elapsed time between the creation of the task and the start of task
execution. (If the task is retried due to failures, the wait time is the
time to the most recent task execution.). This value is only reported in
the account lifetime statistics; it is not included in the job statistics.
:type wait_time: timedelta
"""
_validation = {
'url': {'required': True},
'start_time': {'required': True},
'last_update_time': {'required': True},
'user_cpu_time': {'required': True},
'kernel_cpu_time': {'required': True},
'wall_clock_time': {'required': True},
'read_iops': {'required': True},
'write_iops': {'required': True},
'read_io_gi_b': {'required': True},
'write_io_gi_b': {'required': True},
'num_succeeded_tasks': {'required': True},
'num_failed_tasks': {'required': True},
'num_task_retries': {'required': True},
'wait_time': {'required': True},
}
_attribute_map = {
'url': {'key': 'url', 'type': 'str'},
'start_time': {'key': 'startTime', 'type': 'iso-8601'},
'last_update_time': {'key': 'lastUpdateTime', 'type': 'iso-8601'},
'user_cpu_time': {'key': 'userCPUTime', 'type': 'duration'},
'kernel_cpu_time': {'key': 'kernelCPUTime', 'type': 'duration'},
'wall_clock_time': {'key': 'wallClockTime', 'type': 'duration'},
'read_iops': {'key': 'readIOps', 'type': 'long'},
'write_iops': {'key': 'writeIOps', 'type': 'long'},
'read_io_gi_b': {'key': 'readIOGiB', 'type': 'float'},
'write_io_gi_b': {'key': 'writeIOGiB', 'type': 'float'},
'num_succeeded_tasks': {'key': 'numSucceededTasks', 'type': 'long'},
'num_failed_tasks': {'key': 'numFailedTasks', 'type': 'long'},
'num_task_retries': {'key': 'numTaskRetries', 'type': 'long'},
'wait_time': {'key': 'waitTime', 'type': 'duration'},
}
def __init__(self, **kwargs):
super(JobScheduleStatistics, self).__init__(**kwargs)
self.url = kwargs.get('url', None)
self.start_time = kwargs.get('start_time', None)
self.last_update_time = kwargs.get('last_update_time', None)
self.user_cpu_time = kwargs.get('user_cpu_time', None)
self.kernel_cpu_time = kwargs.get('kernel_cpu_time', None)
self.wall_clock_time = kwargs.get('wall_clock_time', None)
self.read_iops = kwargs.get('read_iops', None)
self.write_iops = kwargs.get('write_iops', None)
self.read_io_gi_b = kwargs.get('read_io_gi_b', None)
self.write_io_gi_b = kwargs.get('write_io_gi_b', None)
self.num_succeeded_tasks = kwargs.get('num_succeeded_tasks', None)
self.num_failed_tasks = kwargs.get('num_failed_tasks', None)
self.num_task_retries = kwargs.get('num_task_retries', None)
self.wait_time = kwargs.get('wait_time', None)
|
