DataFrame + distributed + secede

So from trial and error, it seems like you have to do this:

result = df.apply().persist()
secede()
wait(result)
rejoin()

Every other order seems to cause a deadlock for reason I can’t entirely explain.

1 Like