code: def __iter__(self):
      ## we could fix this up such that tasks are retrieved from the parent process one at a time..
      for i, task in enumerate(self.tasks):
          self.index = i
          # print os.getpid(), 'starting task', i
          self._taskStarted(os.getpid(), i, _callSync="off")
          yield task
      if self.proc is not None:
          # print os.getpid(), 'no more tasks'
          self.proc.close()
  
imports: import multiprocessing
  import os
  import re
  import sys
  import time
  from .processes import ForkedProcess
  from .remoteproxy import ClosedError
label_desc: Use image node_id 2 for calling the Tasker obj's underlying member method code with example usage: obj.__iter__() without return types