add first basic call julia engine tests

Author: jkrumbiegel

.github/workflows/test-smokes.yml

@@ -174,6 +174,18 @@ jobs:
         with:
           version: "1.11.3"
 
+      - name: Checkout dev branch of QuartoNotebookRunner
+        uses: actions/checkout@v4
+        with:
+          repository: PumasAI/QuartoNotebookRunner.jl
+          ref: jk/workers-status
+
+      - name: Set QUARTO_JULIA_PROJECT environment variable
+        run: echo "QUARTO_JULIA_PROJECT=$GITHUB_WORKSPACE/QuartoNotebookRunner.jl" >> $GITHUB_ENV
+
+      - name: Instantiate QuartoNotebookRunner
+        run: julia --project=./QuartoNotebookRunner.jl -e 'using Pkg; Pkg.instantiate()'
+
       - name: Cache Julia Packages
         uses: julia-actions/cache@v2
 

src/execute/julia.ts

@@ -798,7 +798,7 @@ function juliaRuntimeDir(): string {
   }
 }
 
-function juliaTransportFile() {
+export function juliaTransportFile() {
   return join(juliaRuntimeDir(), "julia_transport.txt");
 }
 

tests/docs/call/engine/julia/sleep.qmd

@@ -0,0 +1,9 @@
+---
+engine: julia
+params:
+  sleep_duration: 0
+---
+
+```{julia}
+sleep(sleep_duration)
+```

tests/smoke/call/engine/julia/julia.test.ts

@@ -0,0 +1,65 @@
+import { assert, assertStringIncludes } from "testing/asserts";
+import { docs, quartoDevCmd } from "../../../../utils.ts";
+import { existsSync } from "fs/exists";
+import { juliaTransportFile } from "../../../../../src/execute/julia.ts";
+
+const sleepQmd = docs("call/engine/julia/sleep.qmd");
+assert(existsSync(sleepQmd));
+
+// make sure we don't have a server process running by sending a kill command
+// and then also try to remove the transport file in case one still exists
+const killcmd = new Deno.Command(
+  quartoDevCmd(),
+  {args: ["call", "engine", "julia", "kill"]}
+).outputSync();
+assert(killcmd.success);
+try {
+  await Deno.remove(juliaTransportFile());
+} catch {
+}
+
+Deno.test("kill without server running", () => {
+  const output = new Deno.Command(
+    quartoDevCmd(),
+    {args: ["call", "engine", "julia", "kill"]}
+  ).outputSync();
+  assert(output.success);
+  const stderr = new TextDecoder().decode(output.stderr);
+  assertStringIncludes(stderr, "Julia control server is not running.");
+});
+
+Deno.test("status without server running", () => {
+  const output = new Deno.Command(
+    quartoDevCmd(),
+    {args: ["call", "engine", "julia", "status"]}
+  ).outputSync();
+  assert(output.success);
+  const stderr = new TextDecoder().decode(output.stderr);
+  assertStringIncludes(stderr, "Julia control server is not running.");
+});
+
+Deno.test("status with server and worker running", () => {
+  const render_output = new Deno.Command(
+    quartoDevCmd(),
+    {args: ["render", sleepQmd, "-P", "sleep_duration:0", "--execute-daemon", "60"]}
+  ).outputSync();
+  assert(render_output.success);
+
+  const status_output = new Deno.Command(
+    quartoDevCmd(),
+    {args: ["call", "engine", "julia", "status"]}
+  ).outputSync();
+  assert(status_output.success);
+  const stdout = new TextDecoder().decode(status_output.stdout);
+  assertStringIncludes(stdout, "workers active: 1");
+});
+
+Deno.test("log exists", () => {
+  const log_output = new Deno.Command(
+    quartoDevCmd(),
+    {args: ["call", "engine", "julia", "log"]}
+  ).outputSync();
+  assert(log_output.success);
+  const stdout_log = new TextDecoder().decode(log_output.stdout);
+  assertStringIncludes(stdout_log, "Log started at");
+});