apache_beam.yaml.yaml_testing module

class apache_beam.yaml.yaml_testing.YamlTestCase(pipeline_spec, test_spec, options, fix_tests)[source]

Bases: TestCase

runTest()[source]

fixed_test()[source]

id()[source]

apache_beam.yaml.yaml_testing.run_test(pipeline_spec, test_spec, options=None, fix_failures=False)[source]

apache_beam.yaml.yaml_testing.validate_test_spec(test_spec)[source]

apache_beam.yaml.yaml_testing.inject_test_tranforms(spec, test_spec, fix_failures)[source]

class apache_beam.yaml.yaml_testing.AssertEqualAndRecord(elements, recording_id)[source]

Bases: PTransform

classmethod store_recorded_result(recording_id, value)[source]

classmethod has_recorded_result(recording_id)[source]

classmethod get_recorded_result(recording_id)[source]

classmethod remove_recorded_result(recording_id)[source]

expand(pcoll)[source]

apache_beam.yaml.yaml_testing.create_test(pipeline_spec, options=None, max_num_inputs=40, min_num_outputs=3)[source]

class apache_beam.yaml.yaml_testing.RecordElements(n)[source]

Bases: PTransform

get_and_remove()[source]

expand(pcoll)[source]