pyspark.SparkContext.getJobTags#

SparkContext.getJobTags()[source]#

Get the tags that are currently set to be assigned to all the jobs started by this thread.

Added in version 3.5.0.

Returns:

set of str

the tags that are currently set to be assigned to all the jobs started by this thread.

See also

SparkContext.addJobTag()

SparkContext.removeJobTag()

SparkContext.clearJobTags()

SparkContext.cancelJobsWithTag()

SparkContext.setInterruptOnCancel()

Examples

>>> sc.addJobTag("job_to_cancel")
>>> sc.getJobTags()
{'job_to_cancel'}
>>> sc.clearJobTags()