Task Registry

fluid.scheduler.broker.TaskRegistry

Bases: dict[str, Task[TP]]

A registry of tasks

periodic

periodic()

Iterate over periodic tasks

Source code in fluid/scheduler/broker.py

def periodic(self) -> Iterable[Task]:
    """Iterate over periodic tasks"""
    for task in self.values():
        yield task