[airflow] branch fix-blank-mapped-graph created (now 03f3dc0)

[bb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bbovenzi pushed a change to branch fix-blank-mapped-graph
in repository https://gitbox.apache.org/repos/asf/airflow.git.


      at 03f3dc0  Check if there are instances before adding a count

This branch includes the following new commits:

     new 03f3dc0  Check if there are instances before adding a count

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[airflow] 01/01: Check if there are instances before adding a count

[bb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bbovenzi pushed a commit to branch fix-blank-mapped-graph
in repository https://gitbox.apache.org/repos/asf/airflow.git

commit 03f3dc0cd466a76404f6b5b11d41cdef3a031d87
Author: Brent Bovenzi <br...@gmail.com>
AuthorDate: Mon Mar 21 09:51:45 2022 -0400

    Check if there are instances before adding a count
---
 airflow/www/static/js/graph.js | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/airflow/www/static/js/graph.js b/airflow/www/static/js/graph.js
index 1ba99a8..85407aa 100644
--- a/airflow/www/static/js/graph.js
+++ b/airflow/www/static/js/graph.js
@@ -87,10 +87,16 @@ let innerSvg = d3.select('#graph-svg g');
 // returns true if at least one node is changed
 const updateNodeLabels = (node, instances) => {
   let haveLabelsChanged = false;
-  const label = tasks[node.id] && tasks[node.id].is_mapped
-    ? `${node.id} [${(instances[node.id].mapped_states && instances[node.id].mapped_states.length) || ' '}]`
-    : node.value.label;
-
+  let { label } = node.value;
+  // Check if there is a count of mapped instances
+  if (tasks[node.id] && tasks[node.id].is_mapped) {
+    const count = instances[node.id]
+      && instances[node.id].mapped_states
+      ? instances[node.id].mapped_states.length
+      : ' ';
+
+    label = `${node.id} [${count}]`;
+  }
   if (g.node(node.id) && g.node(node.id).label !== label) {
     g.node(node.id).label = label;
     haveLabelsChanged = true;