worker

Workers for handling task running on pods.

Classes

ProtocolTaskBatchRun

class ProtocolTaskBatchRun():

Hook to report dataset statistics before and after protocol run.

Initialise the hook.

Ancestors

• abc.ABC
• typing.Protocol
• typing.Generic

Methods

---

on_run_end

def on_run_end(    self,    protocol: bitfount.federated.protocols.base._BaseProtocol,    context: TaskContext,    *args: Any,    **kwargs: Any,) ‑> None:

Runs after protocol run to report dataset statistics.

SaveFailedFilesToDatabase

class SaveFailedFilesToDatabase():

Hook to save failed files to database.

Initialise the hook.

Ancestors

• abc.ABC
• typing.Protocol
• typing.Generic

Methods

---

on_resilience_end

def on_resilience_end(    self,    protocol: bitfount.federated.protocols.base._BaseProtocol,    context: TaskContext,    *args: Any,    **kwargs: Any,) ‑> None:

Runs after protocol run to save failed files to database.

SaveResultsToDatabase

class SaveResultsToDatabase():

Hook to save protocol results to database.

Initialise the hook.

Ancestors

• abc.ABC
• typing.Protocol
• typing.Generic

Methods

---

on_run_end

def on_run_end(    self,    protocol: bitfount.federated.protocols.base._BaseProtocol,    context: TaskContext,    *args: Any,    **kwargs: Any,) ‑> None:

Runs after protocol run to save results to database.

---