Update clickhouse query to /views/now (#187)

livepeer · Mar 25, 2024 · 69beb91 · 69beb91
1 parent e1c52d8
commit 69beb91
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/views/clickhouse.go b/views/clickhouse.go
@@ -92,10 +92,9 @@ func (c *ClickhouseClient) QueryTimeSeriesRealtimeViewsEvents(ctx context.Contex
 func buildRealtimeViewsEventsQuery(spec QuerySpec) (string, []interface{}, error) {
 	query := squirrel.Select(
 		"count(distinct session_id) as view_count",
-		"count(distinct if(JSONExtractInt(event_data, 'errors') > 0, session_id, null)) / count(distinct session_id) as error_rate").
-		From("viewership_events").
+		"count(distinct if(errors > 0, session_id, null)) / count(distinct session_id) as error_rate").
+		From("viewership_current_counts").
 		Where("user_id = ?", spec.Filter.UserID).
-		Where("server_timestamp > (toUnixTimestamp(now() - 30)) * 1000").
 		Limit(maxClickhouseResultRows + 1)
 	return toSqlWithFiltersAndBreakdown(query, spec)
 }