Merge pull request #333 from near/main

Prod Release 26/10/23
near · Oct 26, 2023 · 5b97cd3 · 5b97cd3
2 parents 0a97885 + 0c9fa36
commit 5b97cd3
Show file tree

Hide file tree

Showing 4 changed files with 28 additions and 3 deletions.
diff --git a/.github/ISSUE_TEMPLATE/bug_report.md b/.github/ISSUE_TEMPLATE/bug_report.md
@@ -2,7 +2,7 @@
 name: Bug report
 about: Create a report to help us improve
 title: ''
-labels: ''
+labels: 'bug'
 assignees: ''
 
 ---

diff --git a/.github/workflows/close-completed-issues.yml b/.github/workflows/close-completed-issues.yml
@@ -0,0 +1,21 @@
+name: 'Issue States'
+
+on:
+  project_card:
+    types: [created, edited, moved]
+
+permissions:
+  repository-projects: read
+  issues: write
+  pull-requests: write
+
+jobs:
+  action:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: dessant/issue-states@v3
+        with:
+          github-token: ${{ github.token }}
+          open-issue-columns: ''
+          closed-issue-columns: 'Closed, Done'
+          log-output: false
diff --git a/runner/src/metrics.ts b/runner/src/metrics.ts
@@ -7,7 +7,7 @@ const UNPROCESSED_STREAM_MESSAGES = new promClient.Gauge({
   labelNames: ['indexer', 'type'],
 });
 
-const EXECUTION_DURATION = new promClient.Gauge({
+const EXECUTION_DURATION = new promClient.Histogram({
   name: 'queryapi_runner_execution_duration_milliseconds',
   help: 'Time taken to execute an indexer function',
   labelNames: ['indexer', 'type'],

diff --git a/runner/src/stream-handler/stream-handler.ts b/runner/src/stream-handler/stream-handler.ts
@@ -3,7 +3,7 @@ import { Worker, isMainThread } from 'worker_threads';
 
 import { type Message } from './types';
 import { METRICS } from '../metrics';
-import { Gauge } from 'prom-client';
+import { Gauge, Histogram } from 'prom-client';
 
 export default class StreamHandler {
   private readonly worker?: Worker;
@@ -36,5 +36,9 @@ export default class StreamHandler {
     if (METRICS[message.type] instanceof Gauge) {
       (METRICS[message.type] as Gauge).labels(message.labels).set(message.value);
     }
+
+    if (METRICS[message.type] instanceof Histogram) {
+      (METRICS[message.type] as Histogram).labels(message.labels).observe(message.value);
+    }
   }
 }