finpandas.utils.jobs module
Utility for multiprocessing finpandas jobs
- class Jobs
Bases:
object- add_job(f: Callable, *args) None
add a job to be executed
- Parameters
f (Callable) – the function to execute with the job, followed in-order by any arguments.
- execute() Iterable[Any]
execute all jobs
- Returns
the output of each job
- Return type
Iterable
- parmap(f: Callable, X: Iterable[Any]) Iterable[Any]
parralelized mapping function
- Parameters
f (Callable) – function to parallelize operation over
X (Iterable) – the arguments to the function, over N function calls.
- Returns
the N function outputs
- Return type
Iterable
- spawn(f: Callable) Callable
[summary]
- Parameters
f (Callable) – function to spawn a pipe for
- Returns
a function that executes the spawning of the pipe
- Return type
Callable