2d:null 2e:["$","title",null,{"children":"Nautilus Allocated Resources | NRP Nautilus | Observable"}] 33:Td84,// Copyright 2018-2023 Observable, Inc. // Released under the ISC license. // https://observablehq.com/@d3/pie-chart function PieChart(data, { name = ([x]) => x, // given d in data, returns the (ordinal) label value = ([, y]) => y, // given d in data, returns the (quantitative) value title, // given d in data, returns the title text width = 600, // outer width, in pixels height = 600, // outer height, in pixels innerRadius = 0, // inner radius of pie, in pixels (non-zero for donut) outerRadius = Math.min(width, height) / 2, // outer radius of pie, in pixels labelRadius = (innerRadius * 0.2 + outerRadius * 0.8), // center radius of labels format = ",", // a format specifier for values (in the label) names, // array of names (the domain of the color scale) colors, // array of colors for names stroke = innerRadius > 0 ? "none" : "white", // stroke separating widths strokeWidth = 1, // width of stroke separating wedges strokeLinejoin = "round", // line join of stroke separating wedges padAngle = stroke === "none" ? 1 / outerRadius : 0, // angular separation between wedges, in radians } = {}) { data.sort((a,b) => { return parseInt(b.hours) - parseInt(a.hours); }); // Compute values. const N = d3.map(data, name); const V = d3.map(data, value); const I = d3.range(N.length).filter(i => !isNaN(V[i])); // Unique the names. if (names === undefined) names = N; names = new d3.InternSet(names); // Chose a default color scheme based on cardinality. if (colors === undefined) colors = d3.schemeSpectral[names.size]; if (colors === undefined) colors = d3.quantize(t => d3.interpolateSpectral(t * 0.8 + 0.1), names.size); // Construct scales. const color = d3.scaleOrdinal(names, colors); // Compute titles. if (title === undefined) { const formatValue = d3.format(format); title = i => `${formatValue(V[i])}\n${N[i]}`; } else { const O = d3.map(data, d => d); const T = title; title = i => T(O[i], i, data); } // Construct arcs. const arcs = d3.pie().padAngle(padAngle).sort(null).value(i => V[i])(I); const arc = d3.arc().innerRadius(innerRadius).outerRadius(outerRadius); const arcLabel = d3.arc().innerRadius(labelRadius).outerRadius(labelRadius); const svg = d3.create("svg") .attr("width", width) .attr("height", height) .attr("viewBox", [-width / 2, -height / 2, width, height]) .attr("style", "max-width: 100%; height: auto; height: intrinsic;"); svg.append("g") .attr("stroke", stroke) .attr("stroke-width", strokeWidth) .attr("stroke-linejoin", strokeLinejoin) .selectAll("path") .data(arcs) .join("path") .attr("fill", d => color(N[d.data])) .attr("d", arc) .append("title") .text(d => title(d.data)); svg.append("g") .attr("font-family", "sans-serif") .attr("font-size", 12) .attr("text-anchor", "middle") .selectAll("text") .data(arcs) .join("text") .attr("transform", d => `translate(${arcLabel.centroid(d)})`) .selectAll("tspan") .data((d, i) => { const lines = `${title(d.data)}`.split(/\n/); return (d.endAngle - d.startAngle) > 0.25 ? lines : lines.slice(0, 1); }) .join("tspan") .attr("x", 0) .attr("y", (_, i) => `${i * 1.1}em`) .attr("font-weight", (_, i) => i ? null : "bold") .text(d => d); return Object.assign(svg.node(), {scales: {color}}); }34:T108d,rawData = { class NamespaceResource { constructor(namespace, node, resource, value=0) { this.namespace = namespace this.node = node this.resource = this.convertResource(resource) this.value = this.convertValue(value) } convertResource (resource) { if (resource?.includes("amd_com_xilinx")) return "fpga" if (resource == "cpu") return "cpu" if (resource?.includes("nvidia_com")) return "gpu" if (resource == "memory") return "memory" if (resource == "ephemeral_storage") return "storage" return "other" } add(value) { this.value += this.convertValue(value) } convertValue(value) { return (this.resource == 'memory' || this.resource == 'storage') ? parseFloat(value) / 1000000000 : parseFloat(value) } } async function queryPrometheus(query) { var encodedUrl = "https://thanos.nrp-nautilus.io/api/v1/query?query=" + encodeURIComponent(query) return new Promise((resolve, reject) => { fetch(encodedUrl).then((response) => { if (response.ok) { response.json().then((json) => { resolve(json.data.result) }) } else { var errorMessage = `Invalid response: Status ${response.status} ${response.statusText}` dataStatus.status = "failure" dataStatus.error = errorMessage reject(errorMessage) } }).catch((error) => { var errorMessage = `Networking error: ${error}` dataStatus.status = "failure" dataStatus.error = errorMessage reject(errorMessage) }) }) } // Reset Status dataStatus.status = null dataStatus.error = '' var output = [{None: null}] // Input Validation if (form.startDate == "") { dataStatus.error = "Missing Input: Start Date" return output } if (form.endDate == "") { dataStatus.error = "Missing Input: End Date" return output } var today = new Date() var maxDate = new Date('09/15/23') var startDate = new Date(form.startDate) var endDate = new Date(form.endDate) if (startDate > today || endDate > today || startDate >= endDate || startDate < maxDate) { dataStatus.status = "failure" dataStatus.error = "Invalid Date(s)" return output } dataStatus.status = 'pending' const moment = await require('moment') var days = moment(endDate).diff(startDate, "days") var dateRanges = [] for(var weeks = days == 7 ? 0 : Math.floor(days/7); weeks >= 0; weeks-- ) { var searchDays = days - 7*weeks >= 7 || days - 7*weeks == 0 ? 7 : days - 7*weeks var searchEnd = new Date() searchEnd.setTime(endDate.getTime() - 1000*60*60*24*7*weeks) searchEnd = weeks == Math.floor(days/7) ? moment(searchEnd).unix() : moment(searchEnd).unix() + 1 // Don't include overlapping timestamps dateRanges.push([searchDays, searchEnd]) } var allocatedQueries = [] for (const [searchDays, searchEnd] of dateRanges) { allocatedQueries.push(queryPrometheus(`sum_over_time(namespace_allocated_resources[${searchDays}d:1h]@${searchEnd})`)) } var data = [] var isMissingData = false await Promise.allSettled(allocatedQueries).then((queries) => { for (const query of queries) { if (query.value.length == 0) { isMissingData = true } else { for (const value of query.value) { var namespace = value['metric']['namespace'] var node = value['metric']['node'] var resource = value['metric']['resource'] var allocatedValue = value['value'][1] if(namespace && node && resource) { var dataRow = data.find((row) => row.namespace == namespace && row.node == node && row.resource == row.convertResource(resource)) if (dataRow) { dataRow.add(allocatedValue) } else { var namespaceResource = new NamespaceResource(namespace, node, resource, allocatedValue) data.push(namespaceResource) } } } } } }) if (isMissingData) { dataStatus.status = "failure" dataStatus.error = `Missing data, partial query failure` } else { dataStatus.status = "success" } return data }35:[] 31:{"id":"5b6f2fc26c516bb2","slug":"node-allocated-resources-by-namespace","title":"Nautilus Allocated Resources","thumbnail":"1e7926027bab106b151eb7f85ae1155d076b052eb024af4c3e68658727f73653","access_level":"public","create_time":"$D2023-09-21T11:53:00.523Z","update_time":"$D2025-10-24T20:18:05.430Z","view_time":null,"first_public_time":"$D2023-09-21T11:53:00.523Z","has_unpublished_edits":null,"fork":false,"stars":2,"starred":false,"owner":{"type":"team","id":"8671851faf43ebf0","login":"nrp-nautilus","name":"NRP Nautilus","avatar_url":"https://avatars-next.observableusercontent.com/85c1919560b09ca3a26d663970a16af967526a351f93b43563e3664e882c1f6c","tier":"starter_2024"},"version":612,"publish_version":null,"role":null,"authored":false,"authors":[{"type":"individual","id":"46d7bdf5b0802f19","login":"ashton-graves","name":"Ashton Graves","avatar_url":"https://avatars-next.observableusercontent.com/6bb91a3dbde5ee73a8be5ba9d2b9142c27d5176362bda30a361300cabe6a9d1e","tier":null},{"type":"individual","id":"ae05632db3fa530e","login":"derek-weitzel","name":"Derek Weitzel","avatar_url":"https://avatars-next.observableusercontent.com/73385b1a83e789878b1f90e9a590719205146f8501eacd1da17dacd96147a060","tier":null}],"members":[{"type":"individual","id":"46d7bdf5b0802f19","login":"ashton-graves","name":"Ashton Graves","avatar_url":"https://avatars-next.observableusercontent.com/6bb91a3dbde5ee73a8be5ba9d2b9142c27d5176362bda30a361300cabe6a9d1e","tier":null,"role":"editor"},{"type":"team","id":"8671851faf43ebf0","login":"nrp-nautilus","name":"NRP Nautilus","avatar_url":"https://avatars-next.observableusercontent.com/85c1919560b09ca3a26d663970a16af967526a351f93b43563e3664e882c1f6c","tier":"starter_2024","role":"editor"}],"comments":[],"custom_thumbnail":false,"trashed":false,"lapsed":null,"subscribed":null,"forks":7,"collection":{"id":"b3481e5568336d76","slug":"cluster-usage","title":"Cluster usage","owner":{"id":"8671851faf43ebf0","login":"nrp-nautilus","name":"NRP Nautilus"}},"type":"notebook","body":{"title":"Nautilus Allocated Resources","cells":[{"id":0,"value":"# Nautilus Allocated Resources","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":174,"value":"Data gathered since 09-15-23","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":341,"value":"---","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":182,"value":"statusMessage = {\n tick\n var status = dataStatus.status\n var message = \"\"\n if (status == null)\n message = `${dataStatus.error}`\n if (status == 'pending')\n message = \"Gathering Data...\"\n if (status == 'success')\n message = \"Successfully gathered data\"\n if (status == 'failure')\n message = `Error: ${dataStatus.error}`\n var messageString = '

' + message + '

'\n return html`${messageString}`\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":5,"value":"viewof form = Inputs.form({\n startDate: Inputs.text({type: \"date\", label: \"Start Date\"}),\n endDate: Inputs.text({type: \"date\", label: \"End Date\"}),\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":338,"value":"---","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":465,"value":"

Namespace Filter

","pinned":false,"hidden":false,"mode":"html","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":464,"value":"viewof namespaceNameFilter = Inputs.text({label: \"Name:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":463,"value":"viewof namespaceInstitutionFilter = Inputs.text({label: \"Institution:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":462,"value":"viewof namespaceUserInstitutionFilter = Inputs.text({label: \"User Institution:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":461,"value":"viewof selectedNamespaces = Inputs.table(filteredNamespaces, {required: false, value: filteredNamespaces})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":460,"value":"---","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":459,"value":"

Node Filter

","pinned":false,"hidden":false,"mode":"html","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":458,"value":"viewof nodeNameFilter = Inputs.text({label: \"Name:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":457,"value":"viewof nodeRegionFilter = Inputs.text({label: \"Region:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":456,"value":"viewof nodeZoneFilter = Inputs.text({label: \"Zone:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":455,"value":"viewof nodeGPUFilter = Inputs.text({label: \"GPU:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":454,"value":"viewof nodeFPGAFilter = Inputs.text({label: \"FPGA:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":453,"value":"viewof nodeTaintsFilter = Inputs.text({label: \"Taints:\"})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":452,"value":"viewof selectedNodes = Inputs.table(filteredNodes, {required: false, value: filteredNodes})","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":451,"value":"---","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":450,"value":"

Namespace Stats

","pinned":false,"hidden":false,"mode":"html","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":449,"value":"namespaceTable = namespaceTotal","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"namespaceTable","database":"$undefined"},{"id":27,"value":"viewof cpuChart = Plot.plot({\n title: \"CPU Hours Allocated\",\n subtitle: \"Top 25 Namespaces\",\n color: { scheme: \"Reds\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(namespaceTotal.filter(d => d.cpu != undefined && d.cpu > 0).sort((d1, d2) => parseFloat(d2.cpu) - parseFloat(d1.cpu)).splice(0,25), {x: \"cpu\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":16,"value":"viewof namespaceGPUChart = Plot.plot({\n title: \"GPU Hours Allocated\",\n subtitle: \"Top 25 Namespaces\",\n color: { scheme: \"Blues\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(namespaceTotal.filter(d => d.gpu != undefined && d.gpu > 0).sort((d1, d2) => parseFloat(d2.gpu) - parseFloat(d1.gpu)).splice(0,25), {x: \"gpu\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":30,"value":"viewof fpgaChart = Plot.plot({\n title: \"FPGA Hours Allocated\",\n subtitle: \"Top 25 Namespaces\",\n color: { scheme: \"Purples\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(namespaceTotal.filter(d => d.fpga != undefined && d.fpga > 0).sort((d1, d2) => parseFloat(d2.fpga) - parseFloat(d1.fpga)).splice(0,25), {x: \"fpga\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":28,"value":"viewof memoryChart = Plot.plot({\n title: \"Memory Hours Allocated (GB/Hour)\",\n subtitle: \"Top 25 Namespaces\",\n color: { scheme: \"Greens\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(namespaceTotal.filter(d => d.memory != undefined && d.memory > 0).sort((d1, d2) => parseFloat(d2.memory) - parseFloat(d1.memory)).splice(0,25), {x: \"memory\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":32,"value":"viewof storageChart = Plot.plot({\n title: \"Ephemeral Storage Hours Allocated (GB/Hour)\",\n subtitle: \"Top 25 Namespaces\",\n color: { scheme: \"Oranges\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(namespaceTotal.filter(d => d.storage != undefined && d.storage > 0).sort((d1, d2) => parseFloat(d2.storage) - parseFloat(d1.storage)).splice(0,25), {x: \"storage\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":331,"value":"---","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":439,"value":"

Node Stats

","pinned":false,"hidden":false,"mode":"html","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":438,"value":"nodeTable = nodeTotal","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"nodeTable","database":"$undefined"},{"id":437,"value":"viewof nodeCpuChart = Plot.plot({\n title: \"CPU Hours Allocated\",\n subtitle: \"Top 25 Nodes\",\n color: { scheme: \"Reds\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(nodeTotal.filter(d => d.cpu != undefined && d.cpu > 0).sort((d1, d2) => parseFloat(d2.cpu) - parseFloat(d1.cpu)).splice(0,25), {x: \"cpu\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":436,"value":"viewof nodeGPUChart = Plot.plot({\n title: \"GPU Hours Allocated\",\n subtitle: \"Top 25 Nodes\",\n color: { scheme: \"Blues\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(nodeTotal.filter(d => d.gpu != undefined && d.gpu > 0).sort((d1, d2) => parseFloat(d2.gpu) - parseFloat(d1.gpu)).splice(0,25), {x: \"gpu\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":435,"value":"viewof nodeFPGAChart = Plot.plot({\n title: \"FPGA Hours Allocated\",\n subtitle: \"Top 25 Nodes\",\n color: { scheme: \"Purples\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(nodeTotal.filter(d => d.fpga != undefined && d.fpga > 0).sort((d1, d2) => parseFloat(d2.fpga) - parseFloat(d1.fpga)).splice(0,25), {x: \"fpga\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":434,"value":"viewof nodeMemoryChart = Plot.plot({\n title: \"Memory Hours Allocated (GB/Hour)\",\n subtitle: \"Top 25 Nodes\",\n color: { scheme: \"Greens\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(nodeTotal.filter(d => d.memory != undefined && d.memory > 0).sort((d1, d2) => parseFloat(d2.memory) - parseFloat(d1.memory)).splice(0,25), {x: \"memory\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":433,"value":"viewof nodeStorageChart = Plot.plot({\n title: \"Ephemeral Storage Hours Allocated (GB/Hour)\",\n subtitle: \"Top 25 Nodes\",\n color: { scheme: \"Oranges\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(nodeTotal.filter(d => d.storage != undefined && d.storage > 0).sort((d1, d2) => parseFloat(d2.storage) - parseFloat(d1.storage)).splice(0,25), {x: \"storage\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":432,"value":"---","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":431,"value":"

GPU Stats

","pinned":false,"hidden":false,"mode":"html","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":430,"value":"gpuTable = gpuTotal","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"gpuTable","database":"$undefined"},{"id":429,"value":"allocatedGpus = PieChart(gpuTotal, {\n name: d => d.name,\n value: d => d.value,\n width: 600,\n height: 600\n})","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":428,"value":"viewof nodeCpuChart1 = Plot.plot({\n title: \"Top GPUs\",\n color: { scheme: \"Reds\" },\n marginLeft: 150,\n marks: [\n Plot.axisX({anchor: \"top\"}),\n Plot.gridX({stroke: \"black\", strokeOpacity: 1}),\n Plot.barX(gpuTotal.filter(d => d.value != undefined && d.value > 0).sort((d1, d2) => parseFloat(d2.value) - parseFloat(d1.value)).splice(0,25), {x: \"value\", y: \"name\", sort: {y: \"x\", reverse: true}, fill: true}),\n Plot.ruleY([0])\n ],\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":325,"value":"---","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","output":"","database":"$undefined"},{"id":181,"value":"dataStatus = {\n return {\n status: null, \n error: ''\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":188,"value":"clientjs = import(\"https://esm.sh/@open-rpc/client-js\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":187,"value":"namespaces = new Promise(async (resolve, reject) => {\n const transport = new clientjs.HTTPTransport(\"https://portal.nrp.ai/rpc\");\n const client = new clientjs.Client(new clientjs.RequestManager([transport]));\n const results = await client.request({method: 'guest.ListNsInfo', params: []})\n let namespaces = {}\n for (var rawDataRow of rawData) {\n namespaces[rawDataRow.namespace] = {\n Name: rawDataRow.namespace || \"Unknown\",\n PI: \"Unknown\",\n Admins: \"Unknown\",\n Institution: \"Unknown\",\n UserInstitutions: \"Unknown\",\n Description: \"Unknown\"\n }\n }\n for (var namespace of results['Namespaces']) {\n namespaces[namespace.Name] = {\n Name: namespace['Name'],\n PI: namespace['PI'],\n Admins: Array(namespace['Admins']).join(),\n Institution: namespace['Institution'],\n UserInstitutions: Array(namespace['UserInstitutions']).join(),\n Description: namespace['Description']\n }\n }\n resolve(namespaces)\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":426,"value":"nodes = new Promise(async (resolve, reject) => {\n const transport = new clientjs.HTTPTransport(\"https://portal.nrp.ai/rpc\");\n const client = new clientjs.Client(new clientjs.RequestManager([transport]));\n const results = await client.request({method: 'guest.ListNodeInfo', params: []})\n let nodes = {}\n for (var rawDataRow of rawData) {\n nodes[rawDataRow.node] = {\n Name: rawDataRow.node || \"Unknown\",\n Region: \"Unknown\",\n Zone: \"Unknown\",\n Taints: \"Unknown\",\n GPUType: \"Unknown\",\n FPGAType: \"Unknown\"\n }\n }\n for (var node of results['Nodes']) {\n nodes[node.Name] = {\n Name: node.Name,\n Region: node.Region,\n Zone: node.Zone,\n Taints: node.Taints?.map(t => t.key + '=' + t.value)?.join(','),\n GPUType: node.GPUType || \"Unknown\",\n FPGAType: node.FPGAType\n }\n }\n resolve(nodes)\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":425,"value":"filteredNodes = Object.entries(nodes).map(([key, value]) => value).filter((row) => \n (new RegExp(nodeNameFilter)).test(row.Name) && \n (new RegExp(nodeRegionFilter)).test(row.Region) &&\n (new RegExp(nodeZoneFilter)).test(row.Zone) &&\n (new RegExp(nodeGPUFilter)).test(row.GPUType) &&\n (new RegExp(nodeFPGAFilter)).test(row.FPGAType) &&\n (new RegExp(nodeTaintsFilter)).test(row.Taints)\n)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":424,"value":"namespaceTotal = Object.entries(filteredData.reduce((acc, row) => {\n let output = acc\n output[row.namespace] = acc[row.namespace] || {}\n output[row.namespace]['name'] = row.namespace\n output[row.namespace][row.resource] = output[row.namespace][row.resource] ? output[row.namespace][row.resource] : 0\n output[row.namespace][row.resource] += row.value\n return output\n}, {})).map(([key, namespace]) => ({\n name: namespace.name,\n pi: namespaces[namespace.name].PI,\n institution: namespaces[namespace.name].Institution,\n description: namespaces[namespace.name].Description,\n cpu: namespace.cpu || 0,\n gpu: namespace.gpu || 0,\n fpga: namespace.fpga || 0,\n memory: namespace.memory || 0,\n storage: namespace.storage || 0\n}))","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":423,"value":"nodeTotal = Object.entries(filteredData.reduce((acc, row) => {\n let output = acc\n output[row.node] = acc[row.node] || {}\n output[row.node]['name'] = row.node\n output[row.node][row.resource] = output[row.node][row.resource] ? output[row.node][row.resource] : 0\n output[row.node][row.resource] += row.value\n return output\n}, {})).map(([key, node]) => ({\n name: node.name,\n cpu: node.cpu || 0,\n gpu: node.gpu || 0,\n fpga: node.fpga || 0,\n memory: node.memory || 0,\n storage: node.storage || 0,\n gputype: nodes[node.name].GPUType,\n fpgatype: nodes[node.name].FPGAType\n}))","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":422,"value":"gpuTotal = Object.entries(nodeTotal.reduce((acc, row) => {\n let output = acc\n output[row.gputype] = acc[row.gputype] || 0\n output[row.gputype] += row.gpu\n return output\n}, {})).map(([key, value]) => ({\n name: key,\n value: value\n}))","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":421,"value":"filteredData = rawData.filter((data) => {\n return selectedNamespaces.some((selectedNamespace) => selectedNamespace.Name === data.namespace)\n}).filter((data) => {\n return selectedNodes.some((selectedNode) => selectedNode.Name === data.node)\n})","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":420,"value":"filteredNamespaces = Object.entries(namespaces).map(([key, value]) => value).filter((row) => \n (new RegExp(namespaceNameFilter)).test(row.Name) && \n (new RegExp(namespaceInstitutionFilter)).test(row.Institution) &&\n (new RegExp(namespaceUserInstitutionFilter)).test(row.UserInstitutions)\n)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":419,"value":"$33","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":60,"value":"$34","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"},{"id":183,"value":"tick = {\n while(true) {\n yield new Promise(resolve => setTimeout(resolve, 500))\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","output":"$undefined","database":"$undefined"}],"files":"$W35","stdlib":"1","titling":"auto"}} 32:"$31:body"