gigl.src.common.utils.dataflow

Functions

get_sanitized_dataflow_job_name
init_beam_pipeline_options	Can pass in any options i.e. init_beam_pipeline_options(num_workers=1, max_num_workers=32, ...) The options passed in will override default options if we define them.