Questions about TFX? Join us at Google I/O!


Generates task from active execution (if any).

Returns None if a task cannot be generated from active execution.

metadata_handler A handler to access MLMD db.
pipeline The pipeline containing the node.
node The pipeline node for which to generate a task.
executions A sequence of all executions for the given node.
is_cancelled Sets is_cancelled in ExecNodeTask.

A Task proto if active execution exists for the node. None otherwise.

RuntimeError If there are multiple active executions for the node.