Skip to content

Commit

Permalink
updated
Browse files Browse the repository at this point in the history 
Signed-off-by: Ketan Umare <ketan.umare@gmail.com>
  • Loading branch information
@kumare3
kumare3 committed Apr 2, 2021
1 parent 88537f3 commit 6179cef
Show file tree
Hide file tree
Showing 2 changed files with 35 additions and 35 deletions.
34 changes: 17 additions & 17 deletions deployment/stats/prometheus/flytepropeller-dashboard.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -189,7 +189,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:round:abort_error[5m]))*300",
"expr": "sum(rate(flyte:propeller:all:round:abort_error[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -295,7 +295,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(deriv(flyte:propeller:all:round:system_error_unlabeled[5m]))*300",
"expr": "sum(deriv(flyte:propeller:all:round:system_error_unlabeled[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -2119,7 +2119,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:node:perma_system_error_duration_unlabeled_ms_count[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:node:perma_system_error_duration_unlabeled_ms_count[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand All @@ -2133,7 +2133,7 @@
},
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:node:perma_user_error_duration_unlabeled_ms[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:node:perma_user_error_duration_unlabeled_ms[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand All @@ -2147,7 +2147,7 @@
},
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:node:perma_unknown_error_duration_unlabeled_ms[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:node:perma_unknown_error_duration_unlabeled_ms[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -2369,7 +2369,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:workflow:event_recording:success_duration_ms_count[5m])) by (wf) * 300",
"expr": "sum(rate(flyte:propeller:all:workflow:event_recording:success_duration_ms_count[5m])) by (wf)",
"format": "time_series",
"hide": false,
"instant": false,
Expand All @@ -2383,7 +2383,7 @@
},
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:workflow:event_recording:failure_duration_ms_count[5m])) by (wf) * 300",
"expr": "sum(rate(flyte:propeller:all:workflow:event_recording:failure_duration_ms_count[5m])) by (wf)",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -2595,7 +2595,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:node:event_recording:success_duration_ms_count[5m])) by (wf) * 300",
"expr": "sum(rate(flyte:propeller:all:node:event_recording:success_duration_ms_count[5m])) by (wf)",
"format": "time_series",
"hide": false,
"instant": false,
Expand All @@ -2609,7 +2609,7 @@
},
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:node:event_recording:failure_duration_ms_count[5m])) by (wf) * 300",
"expr": "sum(rate(flyte:propeller:all:node:event_recording:failure_duration_ms_count[5m])) by (wf)",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -2821,7 +2821,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:task:event_recording:success_duration_ms_count[5m])) by (wf) * 300",
"expr": "sum(rate(flyte:propeller:all:task:event_recording:success_duration_ms_count[5m])) by (wf)",
"format": "time_series",
"hide": false,
"instant": false,
Expand All @@ -2835,7 +2835,7 @@
},
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:task:event_recording:failure_duration_ms_count[5m])) by (wf) * 300",
"expr": "sum(rate(flyte:propeller:all:task:event_recording:failure_duration_ms_count[5m])) by (wf)",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -3047,7 +3047,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:node:build_dynamic_workflow_us_count[5m])) by (wf) * 300",
"expr": "sum(rate(flyte:propeller:all:node:build_dynamic_workflow_us_count[5m])) by (wf)",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -3153,7 +3153,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:admin_launcher:cache_hit[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:admin_launcher:cache_hit[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand All @@ -3167,7 +3167,7 @@
},
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:admin_launcher:cache_miss[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:admin_launcher:cache_miss[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -3389,7 +3389,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:wf_update_latency_ms_count[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:wf_update_latency_ms_count[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -3495,7 +3495,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:wf_update_conflict[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:wf_update_conflict[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down Expand Up @@ -3601,7 +3601,7 @@
"targets": [
{
"datasource": "",
"expr": "sum(rate(flyte:propeller:all:wf_update_failed[5m])) * 300",
"expr": "sum(rate(flyte:propeller:all:wf_update_failed[5m]))",
"format": "time_series",
"hide": false,
"instant": false,
Expand Down
36 changes: 18 additions & 18 deletions stats/flytepropeller_dashboard.py
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import typing

from grafanalib.core import (
Dashboard, Graph,
Dashboard, Graph, Gauge, Stat,
OPS_FORMAT, Row, SHORT_FORMAT, single_y_axis, Target, YAxes, YAxis, MILLISECONDS_FORMAT, DataSourceInput,
PERCENT_FORMAT, NO_FORMAT
)
Expand Down Expand Up @@ -103,7 +103,7 @@ def system_errors() -> Graph:
dataSource=DATASOURCE,
targets=[
Target(
expr='sum(deriv(flyte:propeller:all:round:system_error_unlabeled[5m]))*300',
expr='sum(deriv(flyte:propeller:all:round:system_error_unlabeled[5m]))',
refId='A',
),
],
Expand All @@ -120,7 +120,7 @@ def abort_errors() -> Graph:
dataSource=DATASOURCE,
targets=[
Target(
expr='sum(rate(flyte:propeller:all:round:abort_error[5m]))*300',
expr='sum(rate(flyte:propeller:all:round:abort_error[5m]))',
refId='A',
),
],
Expand Down Expand Up @@ -351,13 +351,13 @@ def admin_launcher_cache() -> Graph:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:admin_launcher:cache_hit[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:admin_launcher:cache_hit[5m]))',
legendFormat="hit",
refId='A',
),

Target(
expr=f'sum(rate(flyte:propeller:all:admin_launcher:cache_miss[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:admin_launcher:cache_miss[5m]))',
legendFormat="miss",
refId='B',
),
Expand All @@ -384,7 +384,7 @@ def dynamic_wf_build() -> typing.List[Graph]:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:node:build_dynamic_workflow_us_count[5m])) by (wf) * 300',
expr=f'sum(rate(flyte:propeller:all:node:build_dynamic_workflow_us_count[5m])) by (wf)',
refId='A',
),
],
Expand All @@ -411,12 +411,12 @@ def task_event_recording() -> typing.List[Graph]:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:task:event_recording:success_duration_ms_count[5m])) by (wf) * 300',
expr=f'sum(rate(flyte:propeller:all:task:event_recording:success_duration_ms_count[5m])) by (wf)',
legendFormat="success wf",
refId='A',
),
Target(
expr=f'sum(rate(flyte:propeller:all:task:event_recording:failure_duration_ms_count[5m])) by (wf) * 300',
expr=f'sum(rate(flyte:propeller:all:task:event_recording:failure_duration_ms_count[5m])) by (wf)',
legendFormat="failure",
refId='A',
),
Expand Down Expand Up @@ -444,12 +444,12 @@ def node_event_recording() -> typing.List[Graph]:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:node:event_recording:success_duration_ms_count[5m])) by (wf) * 300',
expr=f'sum(rate(flyte:propeller:all:node:event_recording:success_duration_ms_count[5m])) by (wf)',
legendFormat="success",
refId='A',
),
Target(
expr=f'sum(rate(flyte:propeller:all:node:event_recording:failure_duration_ms_count[5m])) by (wf) * 300',
expr=f'sum(rate(flyte:propeller:all:node:event_recording:failure_duration_ms_count[5m])) by (wf)',
legendFormat="failure",
refId='A',
),
Expand Down Expand Up @@ -477,12 +477,12 @@ def wf_event_recording() -> typing.List[Graph]:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:workflow:event_recording:success_duration_ms_count[5m])) by (wf) * 300',
expr=f'sum(rate(flyte:propeller:all:workflow:event_recording:success_duration_ms_count[5m])) by (wf)',
legendFormat="success",
refId='A',
),
Target(
expr=f'sum(rate(flyte:propeller:all:workflow:event_recording:failure_duration_ms_count[5m])) by (wf) * 300',
expr=f'sum(rate(flyte:propeller:all:workflow:event_recording:failure_duration_ms_count[5m])) by (wf)',
legendFormat="failure",
refId='A',
),
Expand Down Expand Up @@ -513,7 +513,7 @@ def wf_store_latency(collapse: bool) -> Row:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:wf_update_latency_ms_count[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:wf_update_latency_ms_count[5m]))',
refId='A',
),
],
Expand All @@ -524,7 +524,7 @@ def wf_store_latency(collapse: bool) -> Row:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:wf_update_conflict[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:wf_update_conflict[5m]))',
refId='A',
),
],
Expand All @@ -535,7 +535,7 @@ def wf_store_latency(collapse: bool) -> Row:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:wf_update_failed[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:wf_update_failed[5m]))',
refId='A',
),
],
Expand Down Expand Up @@ -575,17 +575,17 @@ def node_errors() -> Graph:
dataSource=DATASOURCE,
targets=[
Target(
expr=f'sum(rate(flyte:propeller:all:node:perma_system_error_duration_unlabeled_ms_count[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:node:perma_system_error_duration_unlabeled_ms_count[5m]))',
legendFormat="system error",
refId='A',
),
Target(
expr=f'sum(rate(flyte:propeller:all:node:perma_user_error_duration_unlabeled_ms[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:node:perma_user_error_duration_unlabeled_ms[5m]))',
legendFormat="user error",
refId='A',
),
Target(
expr=f'sum(rate(flyte:propeller:all:node:perma_unknown_error_duration_unlabeled_ms[5m])) * 300',
expr=f'sum(rate(flyte:propeller:all:node:perma_unknown_error_duration_unlabeled_ms[5m]))',
legendFormat="user error",
refId='A',
),
Expand Down

0 comments on commit 6179cef

Please sign in to comment.