Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
08-17-2023 10:50 AM
@Starki - Per documentation,
StreamingQueryListener.onQueryTerminated is called when the query is stopped, e.g., StreamingQuery.stop.
and each of these Python observable APIs work asynchronously.
https://www.databricks.com/blog/2022/05/27/how-to-monitor-streaming-queries-in-pyspark.html