From add4d15b1fe58a186fc7487db879588e437096b0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Fran=C3=A7ois=20Samin?= <francois.samin@corp.ovh.com>
Date: Tue, 7 Apr 2020 11:32:36 +0200
Subject: [PATCH] feat(sql): add view on run nodes (#5108)

---
 engine/sql/196_sql_jobs_view.sql | 34 ++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 engine/sql/196_sql_jobs_view.sql

diff --git a/engine/sql/196_sql_jobs_view.sql b/engine/sql/196_sql_jobs_view.sql
new file mode 100644
index 0000000000..a27c58b1ae
--- /dev/null
+++ b/engine/sql/196_sql_jobs_view.sql
@@ -0,0 +1,34 @@
+-- +migrate Up
+CREATE VIEW view_node_run_job AS 
+SELECT  
+        jobs->>'id' as "id",
+        jobs->>'workflow_node_run_id' as "workflow_node_run_id",
+        jobs->>'status' as "status",
+        cast(jobs->>'start' as timestamp with time zone) as "started", 
+        cast(jobs->>'queued' as timestamp with time zone) as "queued" ,
+        cast(jobs->>'done' as timestamp with time zone) as "done",  
+        jobs->>'retry' as "retry",
+        jobs->>'model' as "model",
+        jobs->>'worker_name' as "worker",
+        jobs->>'hatchery_name' as "hatchery"
+FROM (
+    SELECT 
+        jsonb_array_elements(
+            CASE jsonb_typeof(stages->'run_jobs') 
+            WHEN 'array' THEN stages->'run_jobs'
+            ELSE '[]' END
+        ) jobs
+    FROM (
+        SELECT 
+        jsonb_array_elements(
+            CASE jsonb_typeof(stages) 
+            WHEN 'array' THEN stages 
+            ELSE '[]' END
+        ) stages
+        FROM workflow_node_run
+    ) tmpStages
+) tmpJobs
+order by started desc;
+
+-- +migrate Down
+DROP VIEW view_node_run_job;