def __init__(self, *options):
    super(PigJob, self).__init__(
      {'type': Config().get_option('azkabanpig', 'default.type', 'pig')},
      *options
    )
    try:
      self.path = self.options['pig.script']
    except __HOLE__:
      raise AzkabanError('Missing `\'pig.script\'` option.')
    else:
      # absolute archive paths get trimmed
      self.options['pig.script'] = self.path.lstrip('/')
      self.join_prefix('jvm.args', ' ', '-D%s=%s')
dataset/ETHPy150Open mtth/azkaban/azkaban/ext/pig.py/PigJob.__init__