now.deployment.flow module#

now.deployment.flow.batch(data_list, n=1)[source]#
now.deployment.flow.wait_for_lb(lb_name, ns)[source]#
now.deployment.flow.wait_for_all_pods_in_ns(f, ns, max_wait=1800)[source]#
now.deployment.flow.deploy_k8s(f, ns, tmpdir, kubectl_path)[source]#
now.deployment.flow.deploy_flow(deployment_type, flow_yaml, ns, env_dict, kubectl_path)[source]#