[api] artifacts/ now supports streaming in-progress artifacts back out as they are provided

1 files changed, 5 insertions, 1 deletions

diff --git a/src/ci_driver.rs b/src/ci_driver.rs
index 29a699c..c4a791d 100644
--- a/src/ci_driver.rs
+++ b/src/ci_driver.rs
@@ -414,7 +414,11 @@ async fn handle_artifact(State(ctx): State<(Arc<DbCtx>, mpsc::Sender<RunnerClien
     };
 
     eprintln!("spawning task...");
-    spawn(async move { artifact.store_all(artifact_content).await.unwrap() });
+    let dbctx_ref = Arc::clone(&ctx.0);
+    spawn(async move {
+        artifact.store_all(artifact_content).await.unwrap();
+        dbctx_ref.finalize_artifact(artifact.artifact_id).await.unwrap();
+    });
     eprintln!("done?");
 
     (StatusCode::OK, "").into_response()