assay-workflow 0.1.1

Durable workflow engine with REST+SSE API, PostgreSQL/SQLite backends. Embeddable library or standalone server.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

/* Assay Workflow Dashboard - Queues Component */

var AssayQueues = (function () {
  'use strict';

  let ctx = null;
  let container = null;

  function render(el, context) {
    ctx = context;
    container = el;

    el.innerHTML =
      '<h2 class="section-title">Queues</h2>' +
      '<div id="queues-table-wrap"></div>';

    loadQueues();
  }

  async function loadQueues() {
    var wrap = container.querySelector('#queues-table-wrap');
    try {
      var queues = await ctx.apiFetch('/queues');
      renderTable(wrap, queues || []);
    } catch (err) {
      wrap.innerHTML = '<div class="empty-state"><p>Error: ' + ctx.escapeHtml(err.message) + '</p></div>';
    }
  }

  function renderTable(wrap, queues) {
    if (queues.length === 0) {
      wrap.innerHTML = '<div class="empty-state"><p>No queues found</p></div>';
      return;
    }

    var html =
      '<table class="data-table"><thead><tr>' +
        '<th>Queue</th>' +
        '<th>Pending</th>' +
        '<th>Running</th>' +
        '<th>Workers</th>' +
      '</tr></thead><tbody>';

    for (var i = 0; i < queues.length; i++) {
      var q = queues[i];
      var warn = (q.pending_activities > 0 && q.workers === 0);

      html +=
        '<tr>' +
          '<td class="mono">' + ctx.escapeHtml(q.queue || q.name || '-') + '</td>' +
          '<td>' + (q.pending_activities || 0) +
            (warn ? ' <span class="warning-icon" title="No workers available">&#9888;</span>' : '') +
          '</td>' +
          '<td>' + (q.running_activities || 0) + '</td>' +
          '<td>' + (q.workers || 0) + '</td>' +
        '</tr>';
    }

    html += '</tbody></table>';
    wrap.innerHTML = html;
  }

  return { render: render };
})();