Add time_elapsed variable to track the elapsed time during stream_build()
This commit is contained in:
parent
a2336aa7c8
commit
d243cfd98f
1 changed files with 3 additions and 1 deletions
|
|
@ -142,7 +142,7 @@ async def stream_build(
|
||||||
|
|
||||||
number_of_nodes = len(graph.vertices)
|
number_of_nodes = len(graph.vertices)
|
||||||
update_build_status(cache_service, flow_id, BuildStatus.IN_PROGRESS)
|
update_build_status(cache_service, flow_id, BuildStatus.IN_PROGRESS)
|
||||||
|
time_elapsed = ""
|
||||||
try:
|
try:
|
||||||
user_id = flow_cache["user_id"]
|
user_id = flow_cache["user_id"]
|
||||||
except KeyError:
|
except KeyError:
|
||||||
|
|
@ -175,8 +175,10 @@ async def stream_build(
|
||||||
logger.exception(exc)
|
logger.exception(exc)
|
||||||
params = str(exc)
|
params = str(exc)
|
||||||
valid = False
|
valid = False
|
||||||
|
time_elapsed = format_elapsed_time(time.perf_counter() - start_time)
|
||||||
update_build_status(cache_service, flow_id, BuildStatus.FAILURE)
|
update_build_status(cache_service, flow_id, BuildStatus.FAILURE)
|
||||||
|
|
||||||
|
|
||||||
vertex_id = vertex.parent_node_id if vertex.parent_is_top_level else vertex.id
|
vertex_id = vertex.parent_node_id if vertex.parent_is_top_level else vertex.id
|
||||||
if vertex_id in graph.top_level_vertices:
|
if vertex_id in graph.top_level_vertices:
|
||||||
response = {
|
response = {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue