|View source on GitHub|
generate method is invoked (typically done periodically within an
orchestration loop), concrete classes implementing this interface are expected
to generate tasks to execute nodes in a pipeline IR spec or system tasks (eg:
for garbage collection) based on the state of pipeline execution and related
details stored in an MLMD db.
Note on thread safety: Concrete classes of this interface need not have a
thread-safe implementation. Onus is on the caller to serialize concurrent
generate. Since MLMD db may be updated upon call to
it's also not safe to invoke
generate concurrently on different instances
TaskGenerator that refer to the same MLMD db and the same pipeline IR.
generate() -> List[
Generates a list of tasks to be performed.
A list of