eventutilities_python.testing package

Submodules

eventutilities_python.testing.utils module

eventutilities_python.testing.utils.assert_error_event(record, expected_error_message, expected_stream_name, expected_schema_uri, expected_error_type)

Lil’ helper to assert that an error event looks like it should.

eventutilities_python.testing.utils.read_records_from_flink_row_file_sink(sink: str | SinkDescriptor) → List[Dict[str, Any]]

A helper function for reading JSON records out of a local output path that a Flink sink has written to. Useful for testing the results of a data pipeline after the Sink has written results.

Parameters:

sink – Either a sink directory in which a Flink Row FileSink has written results, Or a file SinkDescriptor from which options.uri will be used as the sink.

Module contents