stream

---

id: py-stream

stream

const stream: Stream

The current stream being processed. Controls message flow, logging, and lifecycle operations like retry and rollback.

---

At a Glance

def on_stream_start():
    stream.logInfo(f'Started: {stream.getName()}')

def on_message():
    # Process and emit
    stream.emit(message, OUTPUT_PORT)

def on_stream_end():
    stream.logInfo(f'Finished: {stream.getName()}')

---

Common Tasks

Task	Method
Emit message	stream.emit(message, port)
Log info	stream.logInfo(msg)
Log warning	stream.logWarning(msg)
Log error	stream.logError(msg)
Get stream name	stream.getName()
Get stream ID	stream.getId()
Get metadata	stream.getMetadata()
Set output name	stream.setOutputName(name)
Set output path	stream.setOutputPath(path)
Request retry	stream.requestRetry(status, delayMs)
Request rollback	stream.requestRollback(status)

---

See Also

• Stream — Full class reference