DataFlow.io

System Status

All Workers Operational

CPU Usage 45%

Running

Last Run Status

Success

Duration

4m 32s -12%

Next Schedule

14:00 UTC

Success Rate

98%

Success Running Pending

postgres_source

245k rows 12s

transform_json

Spark Job 1m 24s

err_handler

Skipped --

agg_metrics

Processing... 45s

load_dw

Pending --

Task Instance: run_20231024_001

Operator PythonOperator

Start Time 14:02:45 UTC

Worker worker-group-b-04

LOGS

[2023-10-24 14:02:45] Starting job...

[2023-10-24 14:02:46] Reading partition 1/4

[2023-10-24 14:02:48] Calculating rolling avg...

> Processing batch 245...

Schedule Interval @daily

Retries 3 times

Concurrency 16 threads

Tags

finance critical

View All

Schema mismatch detected

Node 'postgres_source' returned unexpected column 'vat_rate'

2 hours ago

High latency warning

Execution time exceeded SLA by 45s

Yesterday

Start building stunning web UIs & websites!