shan_chandra
Databricks Employee
Databricks Employee

@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