def main():
    parser = _get_parser()
    if (len(sys.argv) < 2):
        parser.print_help()
        sys.exit(0)
    args = parser.parse_args()
    log_level = ((3 - args.verbose) * 10)
    fmt = '%(asctime)s - %(process)d - %(levelname)s - %(name)s - %(module)s - %(message)s'
    logging.basicConfig(level=log_level, format=fmt)
    with open(args.config) as config_file:
        if (args.config.endswith('yaml') or args.config.endswith('yml')):
            config = yaml.safe_load(config_file)
        else:
            config = json.load(config_file)
    if args.create_pod:
        run_on_kubernetes(config, args.namespace)
    else:
        results = run_dask_function(config)
        if (results is not None):
            print(tabulate.tabulate(results, tablefmt='github', headers=results.columns))
def main():
    parser = _get_parser()
    if (len(sys.argv) < 2):
        parser.print_help()
        sys.exit(0)
    args = parser.parse_args()
    log_level = ((3 - args.verbose) * 10)
    fmt = '%(asctime)s - %(process)d - %(levelname)s - %(name)s - %(module)s - %(message)s'
    logging.basicConfig(level=log_level, format=fmt)
    with open(args.config) as config_file:
        if (args.config.endswith('yaml') or args.config.endswith('yml')):
            config = yaml.safe_load(config_file)
        else:
            config = json.load(config_file)
    if args.create_pod:
        run_on_kubernetes(config, args.namespace)
    else:
        results = run_dask_function(config)
        if (results is not None):
            print(tabulate.tabulate(results, tablefmt='github', headers=results.columns))