1
1
using DaggerWebDash
2
+ import DaggerWebDash: LinePlot, GanttPlot
2
3
using TimespanLogging
3
4
using Dagger
4
5
using Test
@@ -18,22 +19,20 @@ using Test
18
19
# FIXME : logs_df = DataFrame([key=>[] for key in keys(ml.consumers)]...)
19
20
# ts = DaggerWebDash.TableStorage(logs_df)
20
21
# push!(lw.creation_handlers, ts)
21
- if render == " webdash"
22
- d3r = DaggerWebDash. D3Renderer (8080 ) # ; seek_store=ts)
23
- push! (lw. creation_handlers, d3r)
24
- push! (lw. deletion_handlers, d3r)
25
- push! (d3r, GanttPlot (:core , :id , :timeline , :esat , :psat , " Overview" ))
26
- # TODO : push!(d3r, ProfileViewer(:core, :profile, "Profile Viewer"))
27
- push! (d3r, LinePlot (:core , :wsat , " Worker Saturation" , " Running Tasks" ))
28
- push! (d3r, LinePlot (:core , :loadavg , " CPU Load Average" , " Average Running Threads" ))
29
- push! (d3r, LinePlot (:core , :bytes , " Allocated Bytes" , " Bytes" ))
30
- push! (d3r, LinePlot (:core , :mem , " Available Memory" , " % Free" ))
31
- # push!(d3r, GraphPlot(:core, :id, :timeline, :profile, "DAG"))
32
- ml. aggregators[:d3r ] = d3r
33
- end
22
+ d3r = DaggerWebDash. D3Renderer (8080 ) # ; seek_store=ts)
23
+ push! (lw. creation_handlers, d3r)
24
+ push! (lw. deletion_handlers, d3r)
25
+ push! (d3r, GanttPlot (:core , :id , :timeline , :esat , :psat , " Overview" ))
26
+ # TODO : push!(d3r, ProfileViewer(:core, :profile, "Profile Viewer"))
27
+ push! (d3r, LinePlot (:core , :wsat , " Worker Saturation" , " Running Tasks" ))
28
+ push! (d3r, LinePlot (:core , :loadavg , " CPU Load Average" , " Average Running Threads" ))
29
+ push! (d3r, LinePlot (:core , :bytes , " Allocated Bytes" , " Bytes" ))
30
+ push! (d3r, LinePlot (:core , :mem , " Available Memory" , " % Free" ))
31
+ # push!(d3r, GraphPlot(:core, :id, :timeline, :profile, "DAG"))
32
+ ml. aggregators[:d3r ] = d3r
34
33
ml. aggregators[:logwindow ] = lw
35
34
ctx = Context (; log_sink= ml)
36
- A = rand ( Blocks ( 4 , 4 ), 16 , 16 )
37
- @async collect (A * A )
35
+ Dagger . Sch . EAGER_CONTEXT[] = ctx
36
+ fetch (Dagger . @spawn 1 + 1 )
38
37
run (pipeline (` curl -s localhost:8080/index.html` ; stdout = devnull ))
39
38
end
0 commit comments