Skip to content

Commit 05f1eba

Browse files
author
Leonhard Schick
authored
ignore not succeeded executions in cost calculation (#36)
We don't want to include broken executions in the node cost calculation; not succeeded node executions normally don't have an realistic execution time.
1 parent 43b120e commit 05f1eba

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

data_integration/logging/node_cost.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ def node_durations_and_run_times(node: pipelines.Node) -> {tuple: [float, float]
3232
FROM data_integration_node_run node
3333
WHERE node.node_path [ 0 : {'%(level)s'}] = %(path)s
3434
AND array_length(node.node_path, 1) > {'%(level)s'}
35+
AND succeeded = TRUE
3536
GROUP BY node.node_path)
3637
SELECT node_path,
3738
round(avg(avg_duration)::NUMERIC, 1) AS avg_duration,

0 commit comments

Comments
 (0)