dplutils.pipeline.stream.StreamingGraphExecutor.task\_submit
============================================================

.. currentmodule:: dplutils.pipeline.stream

.. automethod:: StreamingGraphExecutor.task_submit