analytics

_sql/analytics/generic_inference/generic_inference_jobs.sql

@@ -21,31 +21,32 @@ limit 50;
 --   sections where models / files get downloaded.
 select *
 from (
-    select
-        jobs.id,
-        u.username,
-        jobs.assigned_worker,
-        jobs.assigned_cluster,
-        jobs.maybe_input_source_token,
-        jobs.maybe_model_token,
-        m.media_source,
-        m.maybe_original_mime_type as mime_type,
-        TRUNCATE(jobs.success_execution_millis / 1000 / 60, 2) as execution_mins,
-        TRUNCATE(jobs.success_inference_execution_millis / 1000 / 60, 2) as inference_mins,
-        TRUNCATE((jobs.success_execution_millis - jobs.success_inference_execution_millis) / 1000 / 60, 2) as extra_mins,
-        jobs.success_execution_millis as execution_millis,
-        m.original_duration_millis as duration_millis,
-        jobs.success_execution_millis / m.original_duration_millis as ratio
-    from generic_inference_jobs AS jobs
-        left join users AS u on
-            u.token = jobs.maybe_creator_user_token
-        left join media_uploads AS m on
-            m.token = jobs.maybe_input_source_token
-    where status != 'pending'
-    and success_execution_millis IS NOT NULL
-    and success_inference_execution_millis IS NOT NULL
-    order by maybe_model_token desc
-        limit 50
+         select
+             jobs.created_at,
+             jobs.id,
+             u.username,
+             jobs.assigned_worker,
+             jobs.assigned_cluster,
+             jobs.maybe_input_source_token,
+             jobs.maybe_model_token,
+             m.media_source,
+             m.maybe_original_mime_type as mime_type,
+             TRUNCATE(jobs.success_execution_millis / 1000 / 60, 2) as execution_mins,
+             TRUNCATE(jobs.success_inference_execution_millis / 1000 / 60, 2) as inference_mins,
+             TRUNCATE((jobs.success_execution_millis - jobs.success_inference_execution_millis) / 1000 / 60, 2) as extra_mins,
+             jobs.success_execution_millis as execution_millis,
+             m.original_duration_millis as duration_millis,
+             jobs.success_execution_millis / m.original_duration_millis as ratio
+         from generic_inference_jobs AS jobs
+                  left join users AS u on
+                 u.token = jobs.maybe_creator_user_token
+                  left join media_uploads AS m on
+                 m.token = jobs.maybe_input_source_token
+         where
+             jobs.status != 'pending'
+        AND jobs.created_at > NOW() - INTERVAL 5 MINUTE
+         order by id desc
+             limit 5000
 ) as t
 order by execution_mins desc;