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)

Reply via email to