code: def processor(ctx, processor_cls, process_time_limit, enable_stdout_capture=True, get_object=False):
      
      g = ctx.obj
      Processor = load_cls(None, None, processor_cls)
  
      processor = Processor(projectdb=g.projectdb,
                            inqueue=g.fetcher2processor, status_queue=g.status_queue,
                            newtask_queue=g.newtask_queue, result_queue=g.processor2result,
                            enable_stdout_capture=enable_stdout_capture,
                            process_time_limit=process_time_limit)
  
      g.instances.append(processor)
      if g.get('testing_mode') or get_object:
          return processor
  
      processor.run()
docs: Run Processor.