More of a higher level library like Beam, and I could see it being plugged into a Prefect workflow.
I don’t see anything on snapshotting or checkpointing like Flink. Is this just for stateless jobs?
But we do have some fault tolerance baked into our I/O operations. Specifically for Google Cloud Pub/Sub the acks don't happen until the data has been successfully processed and written to the sink, so if there is a bug or some transient failure the message will be resent later depending on your subscriber configuration.
This bench mark was consuming a Google Cloud Pub/Sub stream and outputting to BigQuery.