• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Python tasks.Task类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中twitter.pants.tasks.Task的典型用法代码示例。如果您正苦于以下问题:Python Task类的具体用法?Python Task怎么用?Python Task使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了Task类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: __init__

    def __init__(
        self,
        context,
        classpath=None,
        workdir=None,
        nailgun_jar=None,
        args=None,
        stdin=None,
        stderr=sys.stderr,
        stdout=sys.stdout,
    ):
        Task.__init__(self, context)

        self._classpath = classpath
        self._nailgun_jar = nailgun_jar or context.config.get("nailgun", "jar")
        self._ng_server_args = args or context.config.getlist("nailgun", "args")
        self._stdin = stdin
        self._stderr = stderr
        self._stdout = stdout
        self._daemon = context.options.nailgun_daemon

        workdir = workdir or context.config.get("nailgun", "workdir")
        self._pidfile = os.path.join(workdir, "pid")
        self._ng_out = os.path.join(workdir, "stdout")
        self._ng_err = os.path.join(workdir, "stderr")
开发者ID:ewhauser,项目名称:commons,代码行数:25,代码来源:nailgun_task.py


示例2: __init__

  def __init__(self, context, output_dir=None, confs=None):
    Task.__init__(self, context)

    self._output_dir = (
      output_dir
      or context.options.jar_create_outdir
      or context.config.get('jar-create', 'workdir')
    )
    self.transitive = context.options.jar_create_transitive
    self.confs = confs or context.config.getlist('jar-create', 'confs')
    self.compression = ZIP_DEFLATED if context.options.jar_create_compressed else ZIP_STORED

    self.jar_classes = context.options.jar_create_classes or context.products.isrequired('jars')
    if self.jar_classes:
      self.context.products.require('classes')

    self.jar_sources = (
      context.options.jar_create_sources
      or context.products.isrequired('source_jars')
    )

    self.jar_javadoc = (
      context.options.jar_create_javadoc
      or context.products.isrequired('javadoc_jars')
    )
    if self.jar_javadoc:
      context.products.require('javadoc')
开发者ID:billwei,项目名称:commons,代码行数:27,代码来源:jar_create.py


示例3: __init__

  def __init__(self, context):
    Task.__init__(self, context)

    options = context.options
    products = context.products

    self._output_dir = options.jar_create_outdir or context.config.get('jar-create', 'workdir')
    self.transitive = options.jar_create_transitive
    self.confs = context.config.getlist('jar-create', 'confs')
    self.compression = ZIP_DEFLATED if options.jar_create_compressed else ZIP_STORED

    self.jar_classes = products.isrequired('jars') or options.jar_create_classes
    if self.jar_classes:
      products.require_data('classes_by_target')
      products.require_data('resources_by_target')

    self.jar_idl = products.isrequired('idl_jars') or options.jar_create_idl
    if self.jar_idl:
      products.require('idl')

    self.jar_javadoc = products.isrequired('javadoc_jars') or options.jar_create_javadoc
    if self.jar_javadoc:
      products.require('javadoc')

    self.jar_sources = products.isrequired('source_jars') or options.jar_create_sources

    self._jars = {}
开发者ID:alfss,项目名称:commons,代码行数:27,代码来源:jar_create.py


示例4: __init__

  def __init__(self, context, output_dir=None, version=None, java_geninfo=None, python_geninfo=None,
               strict=None, verbose=None):

    Task.__init__(self, context)

    self.thrift_binary = select_binary(
      context.config.get('thrift-gen', 'supportdir'),
      version or context.config.get('thrift-gen', 'version'),
      'thrift'
    )
    self.output_dir = (
      output_dir
      or context.options.thrift_gen_create_outdir
      or context.config.get('thrift-gen', 'workdir')
    )
    self.strict = strict or context.config.getbool('thrift-gen', 'strict')
    self.verbose = verbose or context.config.getbool('thrift-gen', 'verbose')

    def create_geninfo(key):
      gen_info = context.config.getdict('thrift-gen', key)
      gen = gen_info['gen']
      deps = OrderedSet()
      for dep in gen_info['deps']:
        deps.update(context.resolve(dep))
      return ThriftGen.GenInfo(gen, deps)

    self.gen_java = java_geninfo or create_geninfo('java')
    self.gen_python = python_geninfo or create_geninfo('python')
    self.gen_langs = set(context.options.thrift_gen_langs)
开发者ID:billwei,项目名称:commons,代码行数:29,代码来源:thrift_gen.py


示例5: __init__

  def __init__(self, context):
    Task.__init__(self, context)
    self.profile = context.config.get('benchmark-run', 'profile',
                                      default="benchmark-caliper-0.5")
    self.confs = context.config.getlist('benchmark-run', 'confs')
    self.java_args = context.config.getlist('benchmark-run', 'args',
                                            default=['-Xmx1g', '-XX:MaxPermSize=256m'])
    self.agent_profile = context.config.get('benchmark-run', 'agent_profile',
                                            default="benchmark-java-allocation-instrumenter-2.1")
    # TODO(Steve Gury):
    # Find all the target classes from the Benchmark target itself
    # https://jira.twitter.biz/browse/AWESOME-1938
    self.caliper_args = context.options.target_class

    if context.options.memory_profiling:
      self.caliper_args += ['--measureMemory']
      # For rewriting JDK classes to work, the JAR file has to be listed specifically in
      # the JAR manifest as something that goes in the bootclasspath.
      # The MANIFEST list a jar 'allocation.jar' this is why we have to rename it
      agent_jar = os.readlink(profile_classpath(self.agent_profile)[0])
      allocation_jar = os.path.join(os.path.dirname(agent_jar), "allocation.jar")
      # TODO(Steve Gury): Find a solution to avoid copying the jar every run and being resilient
      # to version upgrade
      shutil.copyfile(agent_jar, allocation_jar)
      os.environ['ALLOCATION_JAR'] = str(allocation_jar)

    if context.options.debug:
      self.java_args.extend(context.config.getlist('jvm', 'debug_args'))
      self.caliper_args += ['--debug']
开发者ID:BabyDuncan,项目名称:commons,代码行数:29,代码来源:benchmark_run.py


示例6: __init__

  def __init__(self, context):
    Task.__init__(self, context)

    self.confs = context.config.getlist('junit-run', 'confs')
    self.profile = context.config.get('junit-run', 'profile')

    self.java_args = context.config.getlist('junit-run', 'args', default=[])
    if context.options.junit_run_jvmargs:
      self.java_args.extend(context.options.junit_run_jvmargs)
    if context.options.junit_run_debug:
      self.java_args.extend(context.config.getlist('jvm', 'debug_args'))

    self.test_classes = context.options.junit_run_tests
    self.context.products.require('classes')

    self.outdir = (
      context.options.junit_run_outdir
      or context.config.get('junit-run', 'workdir')
    )

    self.flags = []
    if context.options.junit_run_xmlreport or context.options.junit_run_suppress_output:
      if context.options.junit_run_xmlreport:
        self.flags.append('-xmlreport')
      self.flags.append('-suppress-output')
      self.flags.append('-outdir')
      self.flags.append(self.outdir)
开发者ID:adamsxu,项目名称:commons,代码行数:27,代码来源:junit_run.py


示例7: __init__

  def __init__(self, context, classpath=None, workdir=None):
    Task.__init__(self, context)

    self._classpath = classpath
    self._nailgun_bootstrap_key = 'nailgun'
    nailgun_bootstrap_tools = context.config.getlist('nailgun', 'bootstrap-tools',
                                                     default=[':nailgun-server'])

    self._bootstrap_utils.register_jvm_build_tools(self._nailgun_bootstrap_key, nailgun_bootstrap_tools)

    self._ng_server_args = context.config.getlist('nailgun', 'args')
    self._daemon = context.options.nailgun_daemon

    workdir = workdir or context.config.get('nailgun', 'workdir')

    # Allows us to identify the nailgun process by its cmd-line.
    self._identifier_arg = '-Dpants.ng.identifier=%s' % os.path.relpath(workdir, get_buildroot())

    self._current_pidport = None

    self._ng_out = os.path.join(workdir, 'stdout')
    self._ng_err = os.path.join(workdir, 'stderr')

    # Prevent concurrency issues when starting up a nailgun.
    self._spawn_lock = threading.Lock()
开发者ID:bollwang,项目名称:commons,代码行数:25,代码来源:nailgun_task.py


示例8: __init__

  def __init__(self, context):
    Task.__init__(self, context)
    config = context.config
    self.confs = config.getlist('benchmark-run', 'confs')
    self.jvm_options = config.getlist('benchmark-run', 'args',
                                      default=['-Xmx1g', '-XX:MaxPermSize=256m'])

    self._benchmark_bootstrap_key = 'benchmark-tool'
    benchmark_bootstrap_tools = config.getlist('benchmark-run', 'bootstrap-tools',
                                               default=[':benchmark-caliper-0.5'])
    self._jvm_tool_bootstrapper.register_jvm_tool(self._benchmark_bootstrap_key, benchmark_bootstrap_tools)
    self._agent_bootstrap_key = 'benchmark-agent'
    agent_bootstrap_tools = config.getlist('benchmark-run', 'agent_profile',
                                           default=[':benchmark-java-allocation-instrumenter-2.1'])
    self._jvm_tool_bootstrapper.register_jvm_tool(self._agent_bootstrap_key, agent_bootstrap_tools)

    # TODO(Steve Gury):
    # Find all the target classes from the Benchmark target itself
    # https://jira.twitter.biz/browse/AWESOME-1938
    self.caliper_args = context.options.target_class

    if context.options.memory_profiling:
      self.caliper_args += ['--measureMemory']

    if context.options.debug:
      self.jvm_options.extend(context.config.getlist('jvm', 'debug_args'))
      self.caliper_args += ['--debug']
开发者ID:alfss,项目名称:commons,代码行数:27,代码来源:benchmark_run.py


示例9: __init__

  def __init__(self, context):
    Task.__init__(self, context)

    self.confs = context.config.getlist('junit-run', 'confs')
    self.junit_profile = context.config.get('junit-run', 'junit_profile')
    self.emma_profile = context.config.get('junit-run', 'emma_profile')

    self.junit_runner = (
      context.options.junit_runner
      or context.config.get('junit-run', 'runner',
                            default='com.twitter.common.testing.runner.JUnitConsoleRunner')
    )

    self.java_args = context.config.getlist('junit-run', 'args', default=[])
    if context.options.junit_run_jvmargs:
      self.java_args.extend(context.options.junit_run_jvmargs)
    if context.options.junit_run_debug:
      self.java_args.extend(context.config.getlist('jvm', 'debug_args'))

    self.test_classes = context.options.junit_run_tests
    self.context.products.require('classes')

    self.outdir = (
      context.options.junit_run_outdir
      or context.config.get('junit-run', 'workdir')
    )

    self.coverage = context.options.junit_run_coverage
    self.coverage_filters = context.options.junit_run_coverage_patterns or []
    self.coverage_dir = os.path.join(self.outdir, 'coverage')
    self.coverage_instrument_dir = os.path.join(self.coverage_dir, 'classes')
    self.coverage_metadata_file = os.path.join(self.coverage_dir, 'coverage.em')
    self.coverage_file = os.path.join(self.coverage_dir, 'coverage.ec')

    self.coverage_report_console = context.options.junit_run_coverage_console
    self.coverage_console_file = os.path.join(self.coverage_dir, 'coverage.txt')

    self.coverage_report_xml = context.options.junit_run_coverage_xml
    self.coverage_xml_file = os.path.join(self.coverage_dir, 'coverage.xml')

    self.coverage_report_html_open = context.options.junit_run_coverage_html_open
    self.coverage_report_html = (
      self.coverage_report_html_open
      or context.options.junit_run_coverage_html
    )
    self.coverage = self.coverage or self.coverage_report_html_open
    self.coverage_html_file = os.path.join(self.coverage_dir, 'html', 'index.html')

    self.flags = []
    if context.options.junit_run_xmlreport or context.options.junit_run_suppress_output:
      if context.options.junit_run_fail_fast:
        self.flags.append('-fail-fast')
      if context.options.junit_run_xmlreport:
        self.flags.append('-xmlreport')
      self.flags.append('-suppress-output')
      self.flags.append('-outdir')
      self.flags.append(self.outdir)

    self.only_write_cmd_line = context.options.only_write_cmd_line
开发者ID:nsanch,项目名称:commons,代码行数:59,代码来源:junit_run.py


示例10: setup_parser

 def setup_parser(cls, option_group, args, mkflag):
   Task.setup_parser(option_group, args, mkflag)
   option_group.add_option(mkflag('error_on_collision'),
                           mkflag('error_on_collision', negate=True),
                           dest='exclusives_error_on_collision', default=True,
                           action='callback', callback=mkflag.set_bool,
                           help=("[%default] Signal an error and abort the build if an " +
                                 "exclusives collision is detected"))
开发者ID:alandge,项目名称:twitter-commons,代码行数:8,代码来源:check_exclusives.py


示例11: __init__

    def __init__(self, context):
        Task.__init__(self, context)

        self.url = context.options.confluence_publish_url or context.config.get("confluence-publish", "url")

        self.force = context.options.confluence_publish_force
        self.open = context.options.confluence_publish_open
        self.context.products.require("markdown_html")
开发者ID:satifanie,项目名称:commons,代码行数:8,代码来源:confluence_publish.py


示例12: __init__

 def __init__(self, context):
   Task.__init__(self, context)
   context.products.require('missing_deps')
   self.transitive = context.options.buildlint_transitive
   self.actions = set(context.options.buildlint_actions)
   # Manually apply the default. Can't use flag default, because action is 'append', so
   # diffs would always be printed, even if we only wanted to rewrite.
   if not self.actions:
     self.actions.add('diff')
开发者ID:lxwuchang,项目名称:commons,代码行数:9,代码来源:build_lint.py


示例13: __init__

 def __init__(self, context):
   Task.__init__(self, context)
   self.jvm_args = context.config.getlist('scala-repl', 'jvm_args', default=[])
   if context.options.run_jvmargs:
     for arg in context.options.run_jvmargs:
       self.jvm_args.extend(shlex.split(arg))
   self.confs = context.config.getlist('scala-repl', 'confs')
   self.profile = context.config.get('scala-repl', 'profile')
   self.main = context.config.get('scala-repl', 'main')
开发者ID:ilsanbao,项目名称:commons,代码行数:9,代码来源:scala_repl.py


示例14: __init__

 def __init__(self, context):
     Task.__init__(self, context)
     self.jvm_args = context.config.getlist("scala-repl", "jvm_args", default=[])
     if context.options.run_jvmargs:
         for arg in context.options.run_jvmargs:
             self.jvm_args.extend(shlex.split(arg))
     self.confs = context.config.getlist("scala-repl", "confs")
     self.profile = context.config.get("scala-repl", "profile")
     self.main = context.config.get("scala-repl", "main")
开发者ID:satifanie,项目名称:commons,代码行数:9,代码来源:scala_repl.py


示例15: setup_parser

  def setup_parser(cls, option_group, args, mkflag):
    Task.setup_parser(option_group, args, mkflag)

    option_group.add_option(mkflag("transitive"), mkflag("transitive", negate=True),
      dest="buildlint_transitive", default=False,
      action="callback", callback=mkflag.set_bool,
      help="[%default] apply lint rules transitively to all dependency buildfiles.")

    option_group.add_option(mkflag("action"), dest="buildlint_actions", default=[],
      action="append", type="choice", choices=['diff', 'rewrite'],
      help="diff=print out diffs, rewrite=apply changes to BUILD files directly.")
开发者ID:lxwuchang,项目名称:commons,代码行数:11,代码来源:build_lint.py


示例16: __init__

  def __init__(self, context, classpath=None, workdir=None, nailgun_jar=None, args=None):
    Task.__init__(self, context)

    self._classpath = classpath
    self._nailgun_jar = nailgun_jar or context.config.get('nailgun', 'jar')
    self._ng_server_args = args or context.config.getlist('nailgun', 'args')

    workdir = workdir or context.config.get('nailgun', 'workdir')
    self._pidfile = os.path.join(workdir, 'pid')
    self._ng_out = os.path.join(workdir, 'stdout')
    self._ng_err = os.path.join(workdir, 'stderr')
开发者ID:billwei,项目名称:commons,代码行数:11,代码来源:nailgun_task.py


示例17: __init__

        def __init__(self, context):
          Task.__init__(self, context)

          if not args:
            self.action = lambda targets: action()
          elif len(args) == 1:
            self.action = lambda targets: action(self.context)
          elif len(args) == 2:
            self.action = lambda targets: action(self.context, targets)
          else:
            raise AssertionError('Unexpected fallthrough')
开发者ID:CodeWarltz,项目名称:commons,代码行数:11,代码来源:__init__.py


示例18: __init__

  def __init__(self, context, classpath=None, workdir=None):
    Task.__init__(self, context)

    self._classpath = classpath
    self._nailgun_profile = context.config.get('nailgun', 'profile', default='nailgun')
    self._ng_server_args = context.config.getlist('nailgun', 'args')
    self._daemon = context.options.nailgun_daemon

    workdir = workdir or context.config.get('nailgun', 'workdir')
    self._pidfile = os.path.join(workdir, 'pid')
    self._ng_out = os.path.join(workdir, 'stdout')
    self._ng_err = os.path.join(workdir, 'stderr')
开发者ID:achun2080,项目名称:commons,代码行数:12,代码来源:nailgun_task.py


示例19: __init__

  def __init__(self, context, output_dir=None, confs=None):
    Task.__init__(self, context)

    self._output_dir = (
      output_dir
      or context.options.javadoc_gen_outdir
      or context.config.get('javadoc-gen', 'workdir')
    )
    self.transitive = context.options.javadoc_gen_transitive
    self.confs = confs or context.config.getlist('javadoc-gen', 'confs')
    self.open = context.options.javadoc_gen_open
    self.combined = self.open or context.options.javadoc_gen_combined
开发者ID:avadh,项目名称:commons,代码行数:12,代码来源:javadoc_gen.py


示例20: __init__

  def __init__(self, context):
    Task.__init__(self, context)

    self.url = (
      context.options.confluence_publish_url
      or context.config.get('confluence-publish', 'url')
    )

    self.force = context.options.confluence_publish_force
    self.open = context.options.confluence_publish_open
    self.context.products.require('markdown_html')
    self._wiki = None
开发者ID:JoeEnnever,项目名称:commons,代码行数:12,代码来源:confluence_publish.py



注:本文中的twitter.pants.tasks.Task类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python jvm_compiler_dependencies.Dependencies类代码示例发布时间:2022-05-27
下一篇:
Python targets.InternalTarget类代码示例发布时间:2022-05-27
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap