pyspark.BarrierTaskContext.attemptNumber

BarrierTaskContext.attemptNumber() → int

How many times this task has been attempted. The first task attempt will be assigned attemptNumber = 0, and subsequent attempts will have increasing attempt numbers.

Returns

int

current attempt number.

pyspark.BarrierTaskContext.allGather pyspark.BarrierTaskContext.barrier