batch

prefect_aws.batch

Tasks for interacting with AWS Batch

Functions

abatch_submit

abatch_submit(job_name: str, job_queue: str, job_definition: str, aws_credentials: AwsCredentials, **batch_kwargs: Optional[Dict[str, Any]]) -> str

Asynchronously submit a job to the AWS Batch job service.

Args:

• job_name: The AWS batch job name.
• job_queue: Name of the AWS batch job queue.
• job_definition: The AWS batch job definition.
• aws_credentials: Credentials to use for authentication with AWS.
• **batch_kwargs: Additional keyword arguments to pass to the boto3 submit_job function. See the documentation for submit_job for more details.

Returns:

• The id corresponding to the job.

batch_submit

batch_submit(job_name: str, job_queue: str, job_definition: str, aws_credentials: AwsCredentials, **batch_kwargs: Optional[Dict[str, Any]]) -> str

Submit a job to the AWS Batch job service.

Args:

• job_name: The AWS batch job name.
• job_queue: Name of the AWS batch job queue.
• job_definition: The AWS batch job definition.
• aws_credentials: Credentials to use for authentication with AWS.
• **batch_kwargs: Additional keyword arguments to pass to the boto3 submit_job function. See the documentation for submit_job for more details.

Returns:

• The id corresponding to the job.