Function test_persist

dask/tests/test_distributed.py:72–77 · view source on GitHub ↗

(c, s, a, b)

Source from the content-addressed store, hash-verified

70
71	@gen_cluster(client=True)
72	async def test_persist(c, s, a, b):
73	x = delayed(inc)(1)
74	x2 = c.persist(x)
75
76	await wait(x2)
77	assert x2.key in a.data or x2.key in b.data
78
79
80	def test_persist_nested(c):

nothing calls this directly

delayedFunction · 0.90

waitFunction · 0.85

persistMethod · 0.45

no test coverage detected