Home
last modified time | relevance | path

Searched refs:get_task_stream (Results 1 – 7 of 7) sorted by relevance

/dports/devel/py-dask/dask-2021.11.2/docs/source/
H A Ddiagnostics-distributed.rst55 get_task_stream
60 offline processing using the ``get_task_stream`` and ``Client.profile``
66 with get_task_stream(plot='save', filename="task-stream.html") as ts:
181 .. autofunction:: get_task_stream
H A Dchangelog.rst2043 - Add get_task_stream and profile to the diagnostics page (:pr:`5375`) `Matthew Rocklin`_
/dports/devel/py-distributed/distributed-2021.11.2/docs/source/
H A Dapi.rst63 get_task_stream
167 .. autoclass:: get_task_stream
H A Dchangelog.rst1072 - Add Resouces option to ``get_task_stream`` and call ``output_file`` (:pr:`3653`) `Prasun Anand`_
1877 - Add documentation for gist/rawgit for get_task_stream (:pr:`2236`) `Matthew Rocklin`_
1905 - Add plot= keyword to get_task_stream (:pr:`2198`) `Matthew Rocklin`_
/dports/devel/py-distributed/distributed-2021.11.2/distributed/
H A D__init__.py19 get_task_stream,
H A Dclient.py4081 def get_task_stream( member in Client
4170 msgs = await self.scheduler.get_task_stream(start=start, stop=stop, count=count)
4866 class get_task_stream: class
4921 self.client.get_task_stream(start=0, stop=0) # ensure plugin
4928 L = self.client.get_task_stream(
4939 L = await self.client.get_task_stream(
4989 await get_client().get_task_stream(start=0, stop=0) # ensure plugin
H A Dscheduler.py3885 "get_task_stream": self.get_task_stream,
7178 def get_task_stream(self, comm=None, start=None, stop=None, count=None): member in Scheduler
7511 task_stream = self.get_task_stream(start=start)