dplutils.pipeline.stream.StreamingGraphExecutor.poll\_tasks
===========================================================

.. currentmodule:: dplutils.pipeline.stream

.. automethod:: StreamingGraphExecutor.poll_tasks