Skip to main content

helper

Helper functions.

Module

Functions

combine_pod_schemas

def combine_pod_schemas(pod_names: Sequence[str])> BitfountSchema:

Combines the schemas of multiple pods into a single schema.

Simply aggregates all the tables in the schemas of the pods into a single schema.

Arguments

  • pod_names: The names of the pods whose schemas will be combined.

Returns The combined schema.

Raises

  • BitfountSchemaError: If the schemas of the pods are incompatible.

Classes

TaskContext

class TaskContext(value, names=None, *, module=None, qualname=None, type=None, start=1):

Describes the context (modeller or worker) in which the task is running.

This is used for models where the model differs depending on if it is on the modeller-side or worker-side of the federated process. It is also used for batched execution.

Ancestors

Variables

  • static MODELLER
  • static WORKER