code: def worker(self, sock):
          
          setproctitle('oq-zworker')
          with sock:
              for cmd, args, mon in sock:
                  parallel.safely_call(cmd, args, mon)
docs: :param sock: a zeromq.Socket of kind PULL receiving (cmd, args)