pyspark.sql.SparkSession.interruptTag

SparkSession.interruptTag(tag)

Interrupt all operations of this session with the given operation tag.

New in version 3.5.0.

Changed in version 4.0.0: Supports Spark Classic.

Returns

list of str

List of operationIds of interrupted operations.

Notes

There is still a possibility of operation finishing just as it is interrupted.