Guest User

Untitled

a guest
Jun 21st, 2018
79
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.30 KB | None | 0 0
  1. WITH dags as(
  2. SELECT dag_id
  3. FROM dag
  4. WHERE is_paused is False
  5. ),
  6.  
  7. rate as (
  8. SELECT dag_id,
  9. SUM(CASE WHEN state='success' THEN 1 ELSE 0 END)*1.0/COUNT(*) as success_rate
  10. FROM dag_run
  11. GROUP BY dag_id
  12. )
  13. SELECT rate.*
  14. FROM rate
  15. RIGHT JOIN dags on dags.dag_id = rate.dag_id
  16. ORDER BY rate.dag_id;
Add Comment
Please, Sign In to add comment