feat(run): force a gc after every notebook run

Author: pankgeorg

src/evaluation/Run.jl

@@ -32,6 +32,7 @@ function run_reactive!(
         )
     end
     try_event_call(session, NotebookExecutionDoneEvent(notebook, user_requested_run))
+	WorkspaceManager.gc_worker((session, notebook))
 	return topological_order
 end
 
@@ -487,6 +488,7 @@ function update_save_run!(
             session,
             NotebookExecutionDoneEvent(notebook, get(kwargs, :user_requested_run, true))
         )
+		WorkspaceManager.gc_worker((session, notebook))
 		topological_order
     end
 end

src/evaluation/WorkspaceManager.jl

@@ -712,4 +712,17 @@ function interrupt_workspace(session_notebook::Union{SN,Workspace}; verbose=true
     end
 end
 
+function gc_worker(session_notebook::SN)
+    workspace = get_workspace(session_notebook)
+    
+    bytes = Malt.remote_eval_fetch(workspace.worker, quote
+        bytes1 = Base.gc_live_bytes()
+        Base.GC.gc(true)
+        bytes2 = Base.gc_live_bytes()
+        bytes1 - bytes2
+    end)
+
+    @debug "   Running succeded, cleanup cleaned $(round(bytes/1024/1024))MBs"
+end
+
 end

src/webserver/GCUtils.jl

@@ -12,10 +12,12 @@ function setup_gc()
     gcfull_metrics = GCFullMetrics(0.0, 0, 0.0)
 
     function gcfull_automatic()
+        b = Base.gc_live_bytes()
         e = @elapsed GC.gc(true)
+        c = Base.gc_live_bytes()
         @atomic gcfull_metrics.last_time = time()
         @atomic gcfull_metrics.counter += 1
-        @debug "GC full run (automatic)" time_taken = e
+        @debug "GC full run (automatic) $(round(100*e)/100)s, $(round(100*(b-c)/1024/1024)/100)MB"
     end
 
     @atomic gcfull_metrics.last_http_call_time = time()