tests.system.apache.beam.example_go¶

用于 Apache Beam Operator 的 Airflow DAG 示例

属性¶

`start_go_pipeline_local_direct_runner`
`test_run`

tests.system.apache.beam.example_go.start_go_pipeline_local_direct_runner[源文件]¶