Source code for src.executors.sequential
from src.executors.base import BaseExecutor
[docs]
class SequentialExecutor(BaseExecutor):
"""Simple sequential executor
Processes arguments in a ``for`` loop.
"""
[docs]
def _execute(self, func, args, **kwargs):
"""Execute ``func`` over ``args`` in a loop.
:meta public:
"""
return [func(arg, **kwargs) for arg in args]
[docs]
def get_n_workers(self):
return 1