polyswarmclient.liveness.liveness

Module Contents

polyswarmclient.liveness.liveness.logger[source]
class polyswarmclient.liveness.liveness.Liveness[source]
last_iteration :int[source]
average_wait :int[source]
class polyswarmclient.liveness.liveness.LivenessCheck(loop_iteration_threshold=5, average_wait_threshold=10)[source]

Bases: abc.ABC

get_liveness(self)[source]
check(self)[source]

Determine if participant is running smoothly, based on given inputs

class polyswarmclient.liveness.liveness.Task(recorder, key, start_time)[source]
class polyswarmclient.liveness.liveness.LivenessRecorder[source]

Bases: abc.ABC

waiting_task(self, key, start_time)[source]

Add waiting task, but remove when done

Use: async with liveness.waiting_task(key, start_time):

Parameters

  • key – task key

  • start_time – start time, in any units (either block number or time)