If your stream object is not compatible with st.write_stream, define a wrapper around your stream object to create a compatible generator function.

for chunk in unsupported_stream:
    yield preprocess(chunk)

For an example, see how we use Replicate with Snowflake Arctic in this code.