MCPcopy Create free account
hub / github.com/XuezheMax/flowseq / parallel_apply

Function parallel_apply

flownmt/flows/parallel/parallel_apply.py:20–79  ·  view source on GitHub ↗

r"""Applies each `module` in :attr:`modules` in parallel on arguments contained in :attr:`inputs` (positional) and :attr:`kwargs_tup` (keyword) on each of :attr:`devices`. :attr:`modules`, :attr:`inputs`, :attr:`kwargs_tup` (if given), and :attr:`devices` (if given) should all have

(flows, inputs, kwargs_tup=None, devices=None, backward=False)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 1

parallel_applyMethod · 0.90

Calls 1

_workerFunction · 0.85

Tested by

no test coverage detected