class_docstr: listen for pipeline events, communicate them as necessary to the
  analysis manager.
class_docstr_tok: ["listen","for","pipeline","events",",","communicate","them","as","necessary","to","the","analysis","manager","."]
code: def __init__(self, handle_exception_fn):
      self.handle_exception_fn = handle_exception_fn
      self.image_set_number = 0
      self.should_abort = False
      self.should_skip = False
  
imports: from cellprofiler_core.constants.worker import ED_STOP, ED_SKIP
  from ..pipeline import RunException
label_desc: Use image node_id 1 to create a new PipelineEventListener object  with example: obj = PipelineEventListener(handle_exception_fn)