some tests
update function defs in streaming
some tests
checkpoint