Did I find the right examples for you? yes no

All Samples(18)  |  Call(17)  |  Derive(0)  |  Import(1)

src/c/e/CellProfiler-HEAD/cellprofiler/analysis_worker.py   CellProfiler(Download)
import cellprofiler.preferences as cpprefs
from cellprofiler.gui.errordialog import ED_STOP, ED_SKIP
from cellprofiler.analysis import \
     PipelinePreferencesRequest, InitialMeasurementsRequest, WorkRequest, \
     NoWorkReply, MeasurementsReport, InteractionRequest, DisplayRequest, \

src/c/e/CellProfiler-HEAD/cellprofiler/gui/pipelinecontroller.py   CellProfiler(Download)
            logger.warning(
                "Failed to display module # %d. The pipeline may have been edited during analysis" % module_num)
            evt.reply(cpanalysis.Ack())
            return
 
        finally:
            # we need to ensure that the reply_cb gets a reply
            evt.reply(cpanalysis.Ack())
 
    def module_display_post_run_request(self, evt):
                                     % (module.module_name, module_num))
        finally:
            evt.reply(cpanalysis.Ack())
 
    def module_interaction_request(self, evt):

src/c/e/CellProfiler-HEAD/cellprofiler/tests/test_analysis.py   CellProfiler(Download)
            self.assertIsInstance(request, cpanalysis.DisplayRequest)
            self.assertEqual(request.foo, "bar")
            request.reply(cpanalysis.Ack(message = "Gimme Pony"))
            reply = fn_interaction_reply()
            self.assertIsInstance(reply, cpanalysis.Ack)
            display_data = request.display_data
            self.assertEqual(display_data["foo"], "bar")
            request.reply(cpanalysis.Ack(message = "Gimme Pony"))
            reply = fn_interaction_reply()
            self.assertIsInstance(reply, cpanalysis.Ack)
                request = self.event_queue.get()
                self.assertEqual(type(request), type(req))
                request.reply(cpanalysis.Ack())
                reply = fn_interaction_reply()
                self.assertIsInstance(reply, cpanalysis.Ack)

src/c/e/CellProfiler-HEAD/cellprofiler/tests/test_analysisworker.py   CellProfiler(Download)
                               'image_pixel_data', 'vmin'])
        self.assertSequenceEqual(d['output_image_pixel_data'].shape, (640, 640))
        req.reply(cpanalysis.Ack())
        #
        # The worker sends ImageSetSuccessWithDictionary.
        for expected, actual in zip(shared_dictionaries, req.shared_dicts):
            self.assertDictEqual(expected, actual)
        req.reply(cpanalysis.Ack())
        #
        # The worker sends the measurement report
        self.assertTrue(m.has_feature("Nuclei", M_LOCATION_CENTER_X))
        self.assertTrue(m.has_feature("Nuclei", "AreaShape_Area"))
        req.reply(cpanalysis.Ack())
        self.awthread.ecute()
 
            req = self.awthread.recv(self.work_socket)
            self.assertIsInstance(req, cpanalysis.DisplayRequest)
            req.reply(cpanalysis.Ack())
            #
            # The worker sends ImageSetSuccess.
            #
            req = self.awthread.recv(self.work_socket)
            self.assertIsInstance(req, cpanalysis.ImageSetSuccess)
            self.assertEqual(req.image_set_number, image_number)
            req.reply(cpanalysis.Ack())