fix: 🐛 Add sys.executable as the Python interpreter in worker scripts.

dacapo/blockwise/argmax_worker.py

@@ -1,4 +1,5 @@
 from pathlib import Path
+import sys
 from dacapo.experiments.datasplits.datasets.arrays.zarr_array import ZarrArray
 from dacapo.store.array_store import LocalArrayIdentifier
 from dacapo.compute_context import create_compute_context
@@ -87,7 +88,8 @@ def spawn_worker(
 
     # Make the command for the worker to run
     command = [
-        "python",
+        # "python",
+        sys.executable,
         path,
         "start-worker",
         "--input_container",

dacapo/blockwise/predict_worker.py

@@ -1,3 +1,4 @@
+import sys
 from pathlib import Path
 
 import torch
@@ -208,7 +209,8 @@ def spawn_worker(
 
     # Make the command for the worker to run
     command = [
-        "python",
+        # "python",
+        sys.executable,
         path,
         "start-worker",
         "--run-name",

dacapo/blockwise/relabel_worker.py

@@ -1,5 +1,6 @@
 from glob import glob
 import os
+import sys
 import daisy
 from dacapo.compute_context import create_compute_context
 from dacapo.store.array_store import LocalArrayIdentifier
@@ -101,7 +102,8 @@ def spawn_worker(
 
     # Make the command for the worker to run
     command = [
-        "python",
+        # "python",
+        sys.executable,
         path,
         "start-worker",
         "--output_container",

dacapo/blockwise/segment_worker.py

@@ -2,6 +2,7 @@
 import logging
 import os
 from pathlib import Path
+import sys
 import click
 import daisy
 from funlib.persistence import Array
@@ -191,7 +192,8 @@ def spawn_worker(
 
     # Make the command for the worker to run
     command = [
-        "python",
+        # "python",
+        sys.executable,
         path,
         "start-worker",
         "--input_container",

dacapo/blockwise/threshold_worker.py

@@ -1,4 +1,5 @@
 from pathlib import Path
+import sys
 from dacapo.experiments.datasplits.datasets.arrays.zarr_array import ZarrArray
 from dacapo.store.array_store import LocalArrayIdentifier
 from dacapo.compute_context import create_compute_context
@@ -89,7 +90,8 @@ def spawn_worker(
 
     # Make the command for the worker to run
     command = [
-        "python",
+        # "python",
+        sys.executable,
         path,
         "start-worker",
         "--input_container",

tests/fixtures/db.py

@@ -36,7 +36,10 @@ def mongo_db_available():
 def options(request, tmp_path):
     # read the options from the users config file locally
     options = Options.instance(
-        type=request.param, runs_base_dir="tests", mongo_db_name="dacapo_tests"
+        type=request.param,
+        runs_base_dir="tests",
+        mongo_db_name="dacapo_tests",
+        compute_context={"type": "LocalTorch", "config": {}},
     )
 
     # change to a temporary directory for this test only