gigl.src.common.utils.dataflow ============================== .. automodule:: gigl.src.common.utils.dataflow .. rubric:: Functions .. autosummary:: :toctree: :nosignatures: :template: base.rst get_sanitized_dataflow_job_name init_beam_pipeline_options