pulsar.scripts package¶

Submodules¶

pulsar.scripts.bootstrap module¶

pulsar.scripts.chown_working_directory module¶

pulsar.scripts.chown_working_directory.main(argv=None)[source]¶

pulsar.scripts.config module¶

class pulsar.scripts.config.PlatformArgumentParser(prog=None, usage=None, description=None, epilog=None, parents=[], formatter_class=<class 'argparse.HelpFormatter'>, prefix_chars='-', fromfile_prefix_chars=None, argument_default=None, conflict_handler='error', add_help=True, allow_abbrev=True, exit_on_error=True)[source]¶

Bases: ArgumentParser

add_argument(dest, ..., name=value, ...)[source]¶
add_argument(option_string, option_string, ..., name=value, ...) → None

pulsar.scripts.config.main(argv=None)[source]¶

pulsar.scripts.drmaa_kill module¶

pulsar.scripts.drmaa_kill.main(argv=None)[source]¶

pulsar.scripts.drmaa_launch module¶

pulsar.scripts.drmaa_launch.main(argv=None)[source]¶

pulsar.scripts.finish module¶

Finish a job submitted with submit.

pulsar.scripts.finish.main(args=None)[source]¶

pulsar.scripts.mesos_executor module¶

class pulsar.scripts.mesos_executor.PulsarExecutor[source]¶

Bases: object

frameworkMessage(driver, message)[source]¶

launchTask(driver, task)[source]¶

pulsar.scripts.mesos_executor.main(argv=None)[source]¶

pulsar.scripts.mesos_executor.run_executor(argv=None)[source]¶

pulsar.scripts.mesos_framework module¶

pulsar.scripts.mesos_framework.main(argv=None)[source]¶

pulsar.scripts.run module¶

CLI related utilities for submitting Pulsar jobs.

pulsar.scripts.run.main(argv=None)[source]¶

pulsar.scripts.submit module¶

Submit a job and wait for it.

pulsar.scripts.submit.main(args=None)[source]¶

pulsar.scripts.submit_util module¶