Warning: This document is for the development version of Pydra: A simple dataflow engine with scalable semantics. The main version is master.

pydra.mark package

pydra.mark.annotate(annotation)

Update the annotation of a function.

Example

>>> import pydra
>>> @pydra.mark.annotate({'a': int, 'return': float})
... def square(a):
...     return a ** 2.0
pydra.mark.task(func)

Promote a function to a FunctionTask.

Example

>>> import pydra
>>> @pydra.mark.task
... def square(a: int) -> float:
...     return a ** 2.0

Submodules