Internalize apposednapari environment

Author: gnodar01

CP5/active_plugins/appose_demo.py

@@ -1,3 +1,4 @@
+import os
 from time import sleep
 
 import appose
@@ -93,12 +94,12 @@ def create_settings(self):
 
         self.package_path = Text(
             "Path to apposednapari environment",
-            "/Users/Nodar/Developer/CellProfiler/apposednapari/.pixi/envs/default",
+            f"{os.path.dirname(__file__)}/apposednapari/.pixi/envs/default",
         )
         self.doit = DoSomething(
             "Do the thing",
             "Do it",
-            self.do_it,
+            lambda: self.send_to_napari(),
             doc=f"""\
 Press this button to do the job.
 """,
@@ -122,50 +123,12 @@ def run(self, workspace):
 
         x_data = x.pixel_data
 
-        env = appose.base(str(self.package_path)).build()
-        with env.python() as python:
-            # Print Appose events verbosely, for debugging purposes.
-            python.debug(print)
-
-            # Start the Qt application event loop in the worker process.
-            print("Starting Qt app event loop")
-            setup = python.task(qt_setup, queue="main")
-            def check_ready(event):
-                if event.response_type == ResponseType.UPDATE:
-                    print("Got update event! Marking Qt as ready")
-                    global READY
-                    READY = True
-                    print("Ready...", READY)
-            print("attempting to start to listen", flush=True)
-            setup.listen(check_ready)
-            print("attempting start setup", flush=True)
-            setup.start()
-            print("Waiting for Qt startup...", flush=True)
-            global READY
-            while not READY:
-                print("sleeping", READY)
-                sleep(0.1)
-            print("Qt is ready!", flush=True)
-
-            print("IMAGE INFO: ", x_data.dtype, x_data.shape)
-
-            # Create a test image in shared memory.
-            ndarr = appose.NDArray(dtype=str(x_data.dtype), shape=x_data.shape)
-            # There's probably a slicker way without needing to slice/copy...
-            ndarr.ndarray()[:] = x_data[:]
-
-            # Actually do a real thing with napari: create and show an image.
-            print("Showing image with napari...", flush=True)
-            task = python.task(napari_show, inputs={"ndarr": ndarr})
-
-            task.wait_for()
-            shape = task.outputs["shape"]
-            print(f"Task complete! Got shape: {shape}", flush=True)
+        self.send_to_napari(x_data)
 
         if self.show_window:
             ...
 
-    def do_it(self):
+    def send_to_napari(self, img_data=None):
         env = appose.base(str(self.package_path)).build()
         with env.python() as python:
             # Print Appose events verbosely, for debugging purposes.
@@ -180,27 +143,29 @@ def check_ready(event):
                     global READY
                     READY = True
                     print("Ready...", READY)
-            print("attempting to start to listen", flush=True)
+            print("attempting to start to listen")
             setup.listen(check_ready)
-            print("attempting start setup", flush=True)
+            print("attempting start setup")
             setup.start()
-            print("Waiting for Qt startup...", flush=True)
+            print("Waiting for Qt startup...")
             global READY
             while not READY:
-                print("sleeping", READY)
+                #print("sleeping", READY)
                 sleep(0.1)
-            print("Qt is ready!", flush=True)
+            print("Qt is ready!")
+
+            if img_data is None:
+                img_data = np.random.random([512, 384]).astype("float64")
 
             # Create a test image in shared memory.
-            ndarr = appose.NDArray(dtype="float64", shape=[512, 384])
-            # Fill the array with random values.
+            ndarr = appose.NDArray(dtype=str(img_data.dtype), shape=img_data.shape)
             # There's probably a slicker way without needing to slice/copy...
-            ndarr.ndarray()[:] = np.random.random(ndarr.shape)
+            ndarr.ndarray()[:] = img_data[:]
 
             # Actually do a real thing with napari: create and show an image.
-            print("Showing image with napari...", flush=True)
+            print("Showing image with napari...")
             task = python.task(napari_show, inputs={"ndarr": ndarr})
 
             task.wait_for()
             shape = task.outputs["shape"]
-            print(f"Task complete! Got shape: {shape}", flush=True)
+            print(f"Task complete! Got shape: {shape}")

CP5/active_plugins/apposednapari/.gitattributes

@@ -0,0 +1,2 @@
+# SCM syntax highlighting & preventing 3-way merges
+pixi.lock merge=binary linguist-language=YAML linguist-generated=true

CP5/active_plugins/apposednapari/.gitignore

@@ -0,0 +1,2 @@
+# pixi environments
+.pixi