hI all i enquired on this long time ago and i have been using this code to set the max timeout on a job Is it still the right way to do it? i am using beam 2.61
Kind regards Marco experiment_value = f"max_workflow_runtime_walltime_seconds={timeout_secs}" pipeline_optionss = PipelineOptions(pipeline_args) pipeline_optionss.view_as(SetupOptions).save_main_session = save_main_session pipeline_optionss.view_as(DebugOptions).add_experiment(experiment_value)