dplutils.pipeline.stream.StreamingGraphExecutor.is_task_ready

abstractmethod StreamingGraphExecutor.is_task_ready(pending_task: Any) → bool

Return true if pending task is ready

This method takes outputs from task_submit() and split_batch_submit() and must return True if the task is complete and can be passed to task_resolve_output() or False otherwise.