Executor¶
-
class laminar.configurations.executors.Executor(concurrency: int =
1
, timeout: int =86400
)¶ Bases:
object
Generic base executor.
Methods
Execute a layer.
Attributes
Number of tasks that can execute concurrently.
Create a semaphore that limits asyncio concurrency.
Number of seconds to wait before automatically failing.
-
__init__(concurrency: int =
1
, timeout: int =86400
)¶
-
concurrency : int =
1
¶ Number of tasks that can execute concurrently.
- property semaphore : Semaphore¶
Create a semaphore that limits asyncio concurrency.
Notes
Concurrency is controled by Executor.concurrency
Usage:
async with self.semaphore: ...
-
timeout : int =
86400
¶ Number of seconds to wait before automatically failing.
-
__init__(concurrency: int =