Skip to content
GitLab
Menu
Projects
Groups
Snippets
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in
Toggle navigation
Menu
Open sidebar
ProfiT-HPC
aggregator
Commits
fa051d67
Commit
fa051d67
authored
Jan 07, 2019
by
Azat Khuziyakhmetov
Browse files
end_time of a job is calculated as start_time + run_time
parent
3e1d857a
Changes
1
Hide whitespace changes
Inline
Side-by-side
db/influx/influxdb_wrapper.py
View file @
fa051d67
...
...
@@ -15,7 +15,7 @@ def fetch_all(job_id, type):
if
type
==
"pdf"
:
t_start
=
data
[
"job"
][
"start_time"
]
t_end
=
data
[
"job"
][
"
end
_time"
]
t_end
=
t_start
+
data
[
"job"
][
"
run
_time"
]
data
[
"seq"
],
data
[
"seq_delta"
]
=
get_seq_data
(
job_id
,
t_start
,
t_end
)
return
data
...
...
@@ -33,7 +33,7 @@ def get_aggregator(job_id, type="ascii"):
aggr
.
job
.
used_queue
=
jd
[
"used_queue"
]
aggr
.
job
.
submit_time
=
jd
[
"submit_time"
]
aggr
.
job
.
start_time
=
jd
[
"start_time"
]
aggr
.
job
.
end_time
=
jd
[
"
end
_time"
]
aggr
.
job
.
end_time
=
jd
[
"
start_time"
]
+
jd
[
"run
_time"
]
aggr
.
job
.
run_time
=
jd
[
"run_time"
]
aggr
.
job
.
requested_time
=
jd
[
"requested_time"
]
aggr
.
job
.
requested_cu
=
jd
[
"requested_cu"
]
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment