Skip to content
  • Code Reference
  • careamics_napari
  • workers
  • prediction_worker

prediction_worker

A thread worker function running CAREamics prediction.

predict_worker(careamist, config_signal, update_queue) #

Model prediction worker.

Parameters:

Name Type Description Default
careamist CAREamist

CAREamist instance.

 required
config_signal PredictionSignal

Prediction signal.

 required
update_queue Queue

Queue used to send updates to the UI.

 required

Yields:

Type Description
Generator[PredictionUpdate, None, None]

Updates.
Source code in src/careamics_napari/workers/prediction_worker.py 
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
@thread_worker
def predict_worker(
    careamist: CAREamist,
    config_signal: PredictionSignal,
    update_queue: Queue,
) -> Generator[PredictionUpdate, None, None]:
    """Model prediction worker.

    Parameters
    ----------
    careamist : CAREamist
        CAREamist instance.
    config_signal : PredictionSignal
        Prediction signal.
    update_queue : Queue
        Queue used to send updates to the UI.

    Yields
    ------
    Generator[PredictionUpdate, None, None]
        Updates.
    """
    # start training thread
    training = Thread(
        target=_predict,
        args=(
            careamist,
            config_signal,
            update_queue,
        ),
    )
    training.start()

    # look for updates
    while True:
        update: PredictionUpdate = update_queue.get(block=True)

        yield update

        if (
            update.type == PredictionUpdateType.STATE
            or update.type == PredictionUpdateType.EXCEPTION
        ):
            break