What happened?
turso client loses the connection - probably because of extended inactivity - to the turso cloud. While this is normal, it cause the whole pipeline to stop (in a controlled way) instead of retrying.
What was expected?
- keep the connection alive
- retry on disconnect
Steps to reproduce
Environment
- DeltaForge version: v0.1.0-beta.5-debug
- Source/Sink/Processor:
- OS: linux
Logs/Error/Details
2025-12-26T23:35:29.422788Z INFO new schema discovered table=orders fingerprint=4bcb931108c8fe3b sequence=1
2025-12-27T05:05:56.571164Z ERROR turso source ended with error error=Connect { details: "Hrana: `api error: `{\"error\":\"stream not found: 1fce4b52:019b5d03-dfd1-78b0-b1c7-ceb6e64dafbb\"}``" }
2025-12-27T05:05:56.651280Z INFO pipeline coordinator exited pipeline=turso2kafka
What happened?
turso client loses the connection - probably because of extended inactivity - to the turso cloud. While this is normal, it cause the whole pipeline to stop (in a controlled way) instead of retrying.
What was expected?
Steps to reproduce
Environment
Logs/Error/Details