Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
21 changes: 21 additions & 0 deletions deepthought/comms.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,19 @@
import rpyc
from rpyc.utils.server import ThreadedServer


def server(object_, port, *args, **kwargs):
"""serving an object in a port.

parameters
--
object_ : object
any python object that needs to be network enabled.
port : int
defines the port where the server is listening for requests.


"""
s = ThreadedServer(object_, hostname="", port=port, auto_register=None,
protocol_config={"allow_all_attrs": True,
"allow_pickle" : True,
Expand All @@ -12,6 +24,15 @@ def server(object_, port, *args, **kwargs):
return s

def client(addr, port, *args, **kwargs):
"""generic function to connect to a rpyc server.

parameters
--
addr : str
ip address/url of the server
port : int
port
"""
obj = rpyc.connect(addr, port, config={
"allow_all_attrs": True, "allow_pickle" : True
})
Expand Down
21 changes: 15 additions & 6 deletions deepthought/configs.py
Original file line number Diff line number Diff line change
@@ -1,26 +1,35 @@
from collections import OrderedDict
from collections import OrderedDict
import os

config = OrderedDict()


def abspath(path):
return os.path.abspath(path)


def read_env_value(name, default):
if name in os.environ:
value = os.environ[name]
else:
value = default
return value


MM_DIR = {
"name" : "MM_DIR",
"default" : "C:\Program Files\Micro-Manager-2.0gamma"
"name": "MM_DIR",
"default": "C:\Program Files\Micro-Manager-2.0gamma"
}
MM_CONFIG = {
"name" : "MM_CONFIG",
"default" : "./mmconfigs/Bright_Star.cfg"
"name": "MM_CONFIG",
"default": "./mmconfigs/Bright_Star.cfg"
}
MM_SERVER = {
"name": "MM_SERVER",
"default": "localhost",
}

config["mm_dir"] = abspath(read_env_value(**MM_DIR))
config["mm_config"] = abspath(read_env_value(**MM_CONFIG))
config["mm_server"] = {"addr": read_env_value(**MM_SERVER), "port": 18861}
store_disk = True
# feature toggle
8 changes: 7 additions & 1 deletion deepthought/detection.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import numpy as np
import tifffile
from cellpose import models

Expand Down Expand Up @@ -27,5 +28,10 @@ def detect_object(image, kind="dapi"):
elif kind == "cyto":
seg_func = segment_cyto

if image.shape[0] > 1:
labels_ = np.array([seg_func(img) for img in image])

return labels_

label_ = seg_func(image)
return (image, label_)
return label_
Loading