Did I find the right examples for you? yes no

All Samples(5)  |  Call(4)  |  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, \
                    self.work_socket.connect(self.work_request_address)
                    # fetch a job 
                    job = self.send(WorkRequest(self.current_analysis_id))
 
                    if isinstance(job, NoWorkReply):

src/c/e/CellProfiler-HEAD/cellprofiler/tests/test_analysisworker.py   CellProfiler(Download)
        def send_something():
            reply = self.awthread.aw.send(cpanalysis.WorkRequest("foo"))
            return reply
        self.awthread.ex(send_something)
        req = self.awthread.recv(self.work_socket)
        def send_something():
            reply = self.awthread.aw.send(cpanalysis.WorkRequest("foo"))
            return reply
        self.awthread.ex(send_something)
        self.cancel()
        def send_something():
            reply = self.awthread.aw.send(cpanalysis.WorkRequest("foo"))
            return reply
        self.awthread.ex(send_something)
        req = self.awthread.recv(self.work_socket)