AWS¶
- class laminar.configurations.executors.AWS¶
Bases:
objectExecute layers in AWS.
Methods
Attributes
-
class Batch(job_queue_arn: str, job_role_arn: str, poll: float =
30.0, concurrency: int =1, timeout: int =86400)¶ Bases:
Executor,_BatchBaseExecute layers in AWS Batch.
Usage:
Flow(executor=AWS.Batch())-
__init__(job_queue_arn: str, job_role_arn: str, poll: float =
30.0, concurrency: int =1, timeout: int =86400)¶
-
concurrency : int =
1¶ Number of tasks that can execute concurrently.
- job_queue_arn : str¶
Amazon resource name (ARN) of an Batch job queue.
- job_role_arn : str¶
Amazon resource name (ARN) of an IAM role to attach to each Batch job.
-
poll : float =
30.0¶ Poll interval wait between requesting a Batch job’s status.
- 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__(job_queue_arn: str, job_role_arn: str, poll: float =
- __init__()¶
-
class Batch(job_queue_arn: str, job_role_arn: str, poll: float =