from atomscale.streaming import TimeseriesStreamer streamer = TimeseriesStreamer(api_key="YOUR_API_KEY") streamer.finalize("d290f1ee-6c54-4b01-90e6-d701748f0851")
{ "data_id": "d290f1ee-6c54-4b01-90e6-d701748f0851", "processed_data_id": "e3a1b2c3-4567-89ab-cdef-234567890abc" }
Finalize a stream, marking it as complete
stream_active
success