Source code for pulsar.scripts.mesos_framework

from pulsar.main import (
    ArgumentParser,
    PulsarManagerConfigBuilder,
)
from pulsar.mesos import ensure_mesos_libs
from pulsar.mesos.framework import run

DESCRIPTION = "Pulsar Mesos Framework Entry Point."




def main(argv=None):
    arg_parser = ArgumentParser(
        description=DESCRIPTION,
    )
    arg_parser.add_argument("--master", default=None, required=True)
    PulsarManagerConfigBuilder.populate_options(arg_parser)
    args = arg_parser.parse_args(argv)
    ensure_mesos_libs()

    config_builder = PulsarManagerConfigBuilder(args)
    config_builder.setup_file_logging()
    config = config_builder.load()

    run(
        master=args.master,
        manager_options=config_builder.to_dict(),
        config=config
    )



if __name__ == "__main__":
    main()